apache-spark - 火花提交错误:java.util.NoSuchElementException:spark.scheduler.mode
问题描述
我正在尝试在 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$1.apply(SparkConf.scala:245)
at org.apache.spark.SparkConf$$anonfun$get$1.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$1(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 标签。
感谢帮助
解决方案
推荐阅读
- android - 如何检测覆盖窗口已隐藏在 Android 12 中
- python-3.x - 如何从不包含@的字符串中提取电子邮件?
- android - 应用程序覆盖活动
- c# - 如果在屏幕上不可见,则自动移动控件
- java - 不同大小的Excel页脚
- ansible - 如果 *any* 主机有事实,如何运行 Ansible 任务
- android - 有没有办法在视频播放时强制对讲宣布使用提示?
- c# - 有没有人在 request.ContentType 中使用 application/edn 从 C# .Net 发布查询请求。引号需要转义序列
- python - 定义 fileinput.input 文件对象的类型
- html - 如何将图像放置在具有不同图像大小的列中