使用 Spark 和 HiveSQL 执行多个查询的问题

Question

我希望有人可以帮助我解决这个问题。在 spark-shell 中，如果我尝试以下操作：

var sqlContext = new org.apache.spark.sql.hive.HiveContext(sc) 

var query = "select * from myDB.table limit 10; drop table if exists"

var queryDF = sqlContext.sql(query)

我收到一个错误：

“org.apache.spark.sql.AnlysisException：在';'处缺少EOF....

我可以很好地执行简单的单行查询……但是多命令查询总是会导致此错误。

有没有人遇到并解决过这个问题？提前致谢！！！

Answer 1

这是预期的行为。SQLContext.sql不支持多个查询，所以解决方案非常简单 - 一次只传递一个查询。