小编wat*_*zup的帖子

我有一个用例，我想在 Flink 上运行 2 个独立的处理流程。所以 2 个流看起来像

Source1 -> operator1 -> Sink1

Source2 -> operator2 -> Sink2

我想为两个流重新使用相同的 Flink 集群。我可以想到通过两种方式来做到这一点：

1) 在同一个 Flink 应用程序上提交 2 个不同的作业

2) 在同一个作业中设置 2 个管道

我能够设置第一个选项，但不确定如何执行第二个选项。有没有人试过这样的设置？一个比另一个有什么优势？