【发布时间】:2017-07-28 14:55:00
【问题描述】:
我在“myJar.jar”中有一个主方法“myMain”(我在 Zeppelin UI 的 spark-interpreter 中加载了这个依赖项)。我已经在 spark 解释器中设置了所有其他 spark 配置。
现在我想提交一个带有 Zeppelin UI 中 myMain 类所需参数的 spark-submit 作业。
类似的东西(在 zeppelin UI 中)(假设我的类采用 -i,-o,-c 参数): --class myMain myJar.jar -i 输入 -o 输出 -c configFile
【问题讨论】:
-
嗨,我刚刚阅读了spark interpreter documentation,我找不到在 UI 中提交 spark jar 的方法。可以使用
conf/zeppelin-env.sh设置SPARK_SUBMIT_OPTIONS -
是的。我可以在 SPARK_SUBMIT_OPTIONS 中设置“--class myMain myJar.jar -i input -o output -c configFile”。但是如何从 UI 启动这个 spark-submit 工作呢?
-
如果您运行 spark 解释器,Zeppelin 将执行您的 spark-submit 作业。例如,
%spark println(1)。 -
准确来说,如果你运行 spark 解释器没有 spark submit 选项,Zeppelin 将执行
RemoteInterpreterServer。但是如果你在zeppelin-env.sh中设置SPARK_SUBMIT_OPTIONS,Zeppelin会启动SparkSubmit进程。您可以通过在终端中执行jps命令来检查。
标签: apache-spark hortonworks-data-platform apache-zeppelin