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 に答える