【问题标题】:Invoke a main method of a jar in zeppelinUI (spark-submit)在 zeppelinUI (spark-submit) 中调用 jar 的 main 方法
【发布时间】: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


【解决方案1】:

我刚刚阅读了spark interpreter documentation,但我找不到在 UI 中提交 spark jar 的方法。

您可以在conf/zeppelin-env.sh 中使用SPARK_SUBMIT_OPTIONS 来代替

更多详情

  • 如果您在没有 spark 提交选项的情况下运行 spark 解释器,Zeppelin 将执行 RemoteInterpreterServer,其中包括本地 spark。
  • 但是如果你在zeppelin-env.sh中设置SPARK_SUBMIT_OPTIONS,Zeppelin会启动SparkSubmit进程。

您可以通过在终端中执行jps 命令来检查。

99212 RemoteInterpreterServer
96926 ZeppelinServer

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2020-04-24
    • 1970-01-01
    • 2014-03-26
    • 1970-01-01
    • 1970-01-01
    • 2013-10-25
    • 2023-02-12
    • 1970-01-01
    相关资源
    最近更新 更多