0

我已成功运行 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]
4

1 回答 1

3

Avi，在您的调用中添加一个 stagingLocation 参数，如下所示：

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

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

于 2015-03-11T17:09:55.807 回答