谷歌DataFlow示例TrafficStreamingMaxLaneFlow执行

Question

我已经成功地运行了WordCount示例，但未能运行TrafficStreamingMaxLaneFlow示例，我到底应该使用什么参数？我的命令行：mvn exec:java -pl examples -Dexec.mainClass=com.google.cloud.dataflow.examples.TrafficStreamingMaxLaneFlow -Dexec.args="--project=sturdy-analyzer-658 --inputTopic=xxxInputTopic --dataset=xxxDataset --table=MIS --runner=BlockingDataflowPipelineRunner"

结果是：

[ERROR] Failed to execute goal org.codehaus.mojo:exec-maven-plugin:1.1:java (default-cli) on project google-cloud-dataflow-java-examples-all: An exception occured while executing the Java class. null: InvocationTargetException: Failed to construct instance from factory method com.google.cloud.dataflow.sdk.runners.BlockingDataflowPipelineRunner#fromOptions: Missing required value: at least one of tempLocation or stagingLocation must be set. -> [Help 1]

Answer 1

Avi，将stagingLocation参数添加到您的调用中，如下所示：

--stagingLocation=gs://your-bucket/staging

确保这是您拥有写入权限的项目中的存储桶。