Ошибка отправки-отправки: java.util.NoSuchElementException: spark.scheduler.mode - PullRequest
0 голосов
/ 20 июня 2019

Я пытаюсь настроить Apache Hudi на сервере Ubuntu 16.04. Я клонировал репо 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)  
...  

Из-за недостаточной репутации я не смог добавить в вопрос тег инкубатора-худи.
Спасибо за помощь

1 Ответ

0 голосов
/ 28 июня 2019

Устранена проблема в обновленном коде

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

...