首页 > 解决方案 > apache zeppelin 上的 zeppelin_ipyspark.py 获取 SyntaxError:无效语法

问题描述

当我在 apache zeppelin 0.8.1 中使用 pyspark 运行代码时,出现类似错误

java.lang.NullPointerException
    at org.apache.thrift.transport.TSocket.open(TSocket.java:170)
    at org.apache.zeppelin.interpreter.remote.ClientFactory.create(ClientFactory.java:51)

...

所以我打开了我的文件夹 zeppelin 中的所有文件

我尝试使用 cmdzeppelin_ipyspark.py运行文件D:\zeppelin-0.8.1-bin-all\interpreter\spark\python

我得到错误

D:\zeppelin-0.8.1-bin-all\interpreter\spark\python>zeppelin_ipyspark.py
  File "D:\zeppelin-0.8.1-bin-all\interpreter\spark\python\zeppelin_ipyspark.py", line 29
    port=${JVM_GATEWAY_PORT}, auth_token=gateway_secret, auto_convert=True))
         ^
SyntaxError: invalid syntax

所以你能帮帮我吗?

标签: pythonapache-sparkpysparkwindows-10apache-zeppelin

解决方案


@LSSzeppelin_ipyspark.py不是独立的脚本。
它作为 Ipython 解释器的一部分从 Zeppelin 的 java 代码内部调用,其中处理 python 脚本以用实际值替换这些字符串(如 JVM_GATEWAY_PORT 等)。
您可以检查代码参考:1 , 2


推荐阅读