Мой код запускает несколько очень похожих заданий потока данных за один прогон. Обычно это работает нормально, но в этом случае шесть заданий запущены нормально, а седьмое дало этот сбой. Что может быть причиной этого?
java.lang.RuntimeException: Failed to create a workflow job: The operation was cancelled.
at org.apache.beam.runners.dataflow.DataflowRunner.run(DataflowRunner.java:869)
at org.apache.beam.runners.dataflow.DataflowRunner.run(DataflowRunner.java:178)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:313)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:299)