spark-submit Error: java.util.NoSuchElementException: spark.scheduler.mode

Question

我正在尝试在 Ubuntu 16.04 服务器上设置 Apache Hudi。我克隆了 repo https://github.com/apache/incubator-hudi.git 然后将其构建为

mvn clean install -DskipTests -DskipITs

构建成功完成。

然后我通过 https://hudi.incubator.apache.org/docker_demo.html

继续进行测试

当我尝试执行

spark-submit --class com.uber.hoodie.utilities.deltastreamer.HoodieDeltaStreamer $HUDI_UTILITIES_BUNDLE --storage-type COPY_ON_WRITE --source-class com.uber.hoodie.utilities.sources.JsonKafkaSource --source-ordering-field ts  --target-base-path /user/hive/warehouse/stock_ticks_cow --target-table stock_ticks_cow --props /var/demo/config/kafka-source.properties --schemaprovider-class com.uber.hoodie.utilities.schema.FilebasedSchemaProvider

我得到了输出

...  
Exception in thread "main" java.util.NoSuchElementException: spark.scheduler.mode  
    at org.apache.spark.SparkConf$$anonfun$get.apply(SparkConf.scala:245)  
    at org.apache.spark.SparkConf$$anonfun$get.apply(SparkConf.scala:245)  
    at scala.Option.getOrElse(Option.scala:121)  
    at org.apache.spark.SparkConf.get(SparkConf.scala:245)  
    at com.uber.hoodie.utilities.deltastreamer.HoodieDeltaStreamer.main(HoodieDeltaStreamer.java:286)  
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)  
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)  
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)  
    at java.lang.reflect.Method.invoke(Method.java:498)  
    at org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52)  
    at org.apache.spark.deploy.SparkSubmit$.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:894)  
    at org.apache.spark.deploy.SparkSubmit$.doRunMain(SparkSubmit.scala:198)  
    at org.apache.spark.deploy.SparkSubmit$.submit(SparkSubmit.scala:228)  
    at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:137)  
    at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)  
...

由于声誉不足，我无法在问题中添加 incubator-hudi 标签。
感谢帮助

Answer 1

问题已在更新的代码中得到解决

https://github.com/apache/incubator-hudi/issues/767
https://github.com/apache/incubator-hudi/pull/758

spark-submit Error: java.util.NoSuchElementException: spark.scheduler.mode

spark-submit Error: java.util.NoSuchElementException: spark.scheduler.mode

apache-spark

ubuntu-16.04

apache-hudi