sql - spark中的hivecontext

Question

我正在尝试在火花中使用 hivecontext。以下语句运行良好：

from pyspark.sql import HiveContext
sqlContext = HiveContext(sc)

但是，当我运行以下语句时，

sqlContext.sql("CREATE TABLE IF NOT EXISTS src (key INT, value STRING)")

我收到以下错误：

Java 包对象不可调用

可能是什么问题呢？