java - Google Cloud Dataflow TextIO 到 BigQueryIO 作业无法启动

Question

我收到以下控制台日志，并且进程停止

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.

我的执行参数如下

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

我在没有指定暂存文件列表的情况下运行了管道，但突然发生了这种情况。

Answer 1

尽管所有日志都是红色的，但日志或代码没有任何问题。我只是忘记运行我的管道。

也许 Eclipse 中的 lint 或标记错误可能有助于避免这种情况。

解决方案:

p.run();

必须添加，因为我不小心删除了该行。