我想在 GCP 上的一个数据流作业中运行两个并行管道。我已经创建了一个管道,它工作得很好,但我想要另一个管道而不创建另一份工作。
我已经搜索了很多答案,但找不到任何代码示例:(
如果我这样运行它就不起作用:
pipe1.run();
pipe2.run();
Run Code Online (Sandbox Code Playgroud)
它给我“已经有一个活动的作业名称...如果您想提交第二个作业,请再次尝试使用--jobName”设置不同的名称
java dataflow google-cloud-platform gcloud google-cloud-dataflow