我有一个在Flink上运行的流束应用程序。a member of class org.apache.beam.runners.spark.structuredstreaming.translation.streaming.DatasetSourceStreaming:251)
at org.apache.beam.sdk.Pipeline.traverseTopologically(Pipeline.java
我正在遵循python指南,并且beam_pipeline可以将作业提交给由.但是我在yarn上有一个spark集群,我将启动命令设置为.: Could not parse Master URL: 'yarn'
spark runner(beam\sdks\python\apache_beam\runners\portability\spark_runnner.py它没有提到
在Apachebeam中,我在java中获得了下面的异常,使用Spark作为一个Runner。我评论了错误的那句话。pipeline = Pipeline.create(options); //Error in this line
以上是代码,下面是错误!!at org.apache.beam.sdk.util.InstanceBuilder.build(InstanceBuilder.java:162)