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 может помочь избежать такого сценария.

Решение:

p.run();

пришлось добавить, так как я случайно удалил эту строку.