【发布时间】:2020-09-12 22:59:41
【问题描述】:
我正在尝试从 Eclipse 中执行示例 WordCount(Java 代码),如 https://cloud.google.com/dataflow/docs/quickstarts/quickstart-java-eclipse#run-the-wordcount-example-pipeline-on-the-cloud-dataflow-service
通过 RunConfiguration 执行时,在 Eclipse 控制台中出现以下错误。
Exception in thread "main" java.lang.IllegalArgumentException: Argument '-output=gs://bucket-for-beam/stage-folder/output-file-prefix' does not begin with '--'
at org.apache.beam.repackaged.beam_sdks_java_core.com.google.common.base.Preconditions.checkArgument(Preconditions.java:191)
at org.apache.beam.sdk.option[s.PipelineOptionsFactory.parseCommandLine(PipelineOptionsFactory.java:1423)
at org.apache.beam.sdk.options.PipelineOptionsFactory.access$200(PipelineOptionsFactory.java:110)
at org.apache.beam.sdk.options.PipelineOptionsFactory$Builder.as(PipelineOptionsFactory.java:294)
at com.gcp.dataflow.examples.WordCount.main(WordCount.java:190)][1]
我创建了一个存储桶,名为“bucket-for-beam”文件夹,名为“stage-folder”:
【问题讨论】:
标签: eclipse apache-beam