:624)Exception in thread "main" java.lang.IllegalArgumentException: requirement failed: No output operations registered, so nothing:624)
at com.streams.spark_consumer.Spark
我写了这段代码来发送来自推特的流数据到elasticsearch,我添加了所有必要的依赖项,但我的两个函数toDS和toES有问题,请帮助我解决这个问题这是我的代码:` `package org.lansrod.visualisationstreaming context
val ACCESS_SECRET = "my access secret"
val CONSUMER_KEY= "my consumer
我已经尝试解决这个问题很长一段时间了。不知道为什么我会有这个吗?仅供参考,我在AWS EMR群集上的群集上运行Spark。我调试过并清楚地看到了提供的目标路径...就像s3://my-bucket-name/一样。spark作业创建orc文件,并在创建分区后写入这些文件,例如:date=2017-06-10。17/07/08 22:48:31 ERROR ApplicationMaster: User class threw exception: java.lang