这个问题在这里已经有了答案：

spark sql安全注意事项（1个答案）
三年前关门了。
脚本：
假设配置单元中有一个表，并使用apachespark中的sparksql查询它，其中表名作为参数传递并连接到查询。
在非分布式系统的情况下，我对sql注入漏洞有基本的了解，在jdbc的上下文中，我了解createstatement/preparedstatement在这类场景中的用法。
但是在sparksql的情况下，这个场景会怎么样呢？这个代码易受攻击吗？有什么见解吗？

def main(args: Array[String]) {

    val sconf = new SparkConf().setAppName("TestApp")
    val sparkContext = new SparkContext(sconf)
    val hiveSqlContext = new org.apache.spark.sql.hive.HiveContext(sparkContext)

    val tableName = args(0)    // passed as an argument

    val tableData  =  hiveSqlContext.sql("select IdNUm, Name from hiveSchemaName." + tableName + " where IdNum <> '' ")
                                        .map( x => (x.getString(0), x.getString(1)) ).collectAsMap()

    ................
    ...............

}