0

スパークで hivecontext を使用しようとしています。次のステートメントは正常に実行されています。

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

しかし、以下のステートメントを実行すると、

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

次のエラーが表示されます。

Java Package オブジェクトを呼び出すことができません

何が問題なのですか?

4

0 に答える 0