我在 Zeppelin 中运行此代码，我收到以下错误消息
from pyspark import SparkContext
from pyspark.sql import HiveContext
sc = SparkContext(appName="PythonSQL")
hive_context = HiveContext(sc)
bank = hive_context.table("default.invites_orc")
bank.show()
bank.registerTempTable("bank_temp")
hive_context.sql("select * from bank_temp").show()
sc.stop()
:1: 错误：';'预期但找到“导入”。 从 pyspark 导入 SparkContext ^
【问题讨论】：
标签： pyspark
Spark Interpreter 组目前有 4 个解释器，如下所示...
https://zeppelin.incubator.apache.org/docs/0.5.0-incubating/interpreter/spark.html
默认解释器是 %spark，默认解释器是根据 zeppelin-site.xml 配置文件中 zeppelin.interpreters 属性中列出的解释器顺序选择的。
zeppelin-site.xml（zeppelin.interpreters 属性）中解释器的当前顺序将是这个......
org.apache.zeppelin.spark.SparkInterpreter,org.apache.zeppelin.spark.PySparkInterpreter 将其修改为 ...
org.apache.zeppelin.spark.PySparkInterpreter, org.apache.zeppelin.spark.SparkInterpreter 并重启 Zeppelin (zeppelin-daemon.sh restart)
这将使 %pyspark 成为默认解释器。
或
你可以这样写
%pyspark
from pyspark import SparkContext
【讨论】：