2016-12-07 10 views
0

を開始していない私は、次のコンソールログを取得していますし、プロセスは、私は指定せずにパイプラインを実行しているGoogleクラウドデータフローTextIOが

--project=xyz-123 --stagingLocation=gs://xxx/staging/ --output=yyy:zzz.aa --runner=BlockingDataflowPipelineRunner 

を次のように

com.google.cloud.dataflow.sdk.runners.DataflowPipelineRunner fromOptions 
INFO: PipelineOptions.filesToStage was not specified. Defaulting to files from the classpath: will stage 69 files. Enable logging at DEBUG level to see which files will be staged. 

マイ実行パラメータは、停止しましたステージングファイルリストが突然現れます。

+1

メインプログラムでp.run()を呼び出しましたか? – jkff

+0

が問題を近づいていた。あなたは、絶対に正しい – Atrix1987

答えて

1

ログはすべて赤で表示されますが、ログやコードに問題はありません。私は単に私のパイプラインを実行することを忘れていた。

Eclipseの糸くずまたはマーカーのエラーがこのような状況を回避するのに役立つかもしれません。

ソリューション:私は誤ってその行を削除し、以降

p.run();

を追加する必要がありました。

関連する問題