【发布时间】:2016-11-17 23:34:31
【问题描述】:
根据http://spark.apache.org/docs/latest/submitting-applications.html#launching-applications-with-spark-submit 应该提交我的Spark 应用程序JAR
./bin/spark-submit \
--class <main-class> \
--master <master-url> \
--deploy-mode <deploy-mode> \
--conf <key>=<value> \
... # other options
<application-jar> \
[application-arguments]
即使我以 SparkSession 开头
val spark = SparkSession
.builder
.getOrCreate()
(因此没有.master("local") 或类似的行)并且没有--master 选项,我的应用程序运行。 http://spark.apache.org/docs/latest/configuration.html#available-properties 页面说 master 没有默认值。这里发生了什么?
【问题讨论】:
-
你确定运行了吗,因为它给了我未定义的主错误!您能否分享您在代码中使用的 SparkConf!
-
@ShivanshSrivastava:据我所知,我没有使用任何 SparkConf。我怎样才能找到它?
-
你能把你的主类的代码贴上来吗!
-
@ShivanshSrivastava:没有任何事情发生了。但是 - 不确定之前的星座是什么 - 现在它按预期失败了。我可以在硬编码的源代码中添加
.master("local")并在 spark-submit-ting 时使用--master选项覆盖它吗?
标签: apache-spark