小编Cha*_*per的帖子

一个数据流作业内的并行管道

我想在 GCP 上的一个数据流作业中运行两个并行管道。我已经创建了一个管道,它工作得很好,但我想要另一个管道而不创建另一份工作。

我已经搜索了很多答案,但找不到任何代码示例:(

如果我这样运行它就不起作用:

pipe1.run();
pipe2.run();
Run Code Online (Sandbox Code Playgroud)

它给我“已经有一个活动的作业名称...如果您想提交第二个作业,请再次尝试使用--jobName”设置不同的名称

java dataflow google-cloud-platform gcloud google-cloud-dataflow

2
推荐指数
1
解决办法
2329
查看次数