Flink流作业执行图分析

Question

我对Flink的性能有一些疑问，

谁能告诉我，如果我的程序有一个与下图相同的执行计划，哪里出了问题？

谢谢。

enter image description here

Answer 1

从您的描述中，我不能立即明白为什么每个源需要多个hash。任何类型的网络混洗都会限制吞吐量，因此避免所有不必要的混洗对您来说似乎是最好的解决方案。

最终的图片应该如下所示

Source 1 --\
            \
Source 2 ----\
              +---> Map ---> Sink
...          /
            /
Source N --/

使得每个输入记录仅被重新键入一次。

除了这些一般性的考虑之外，我还需要更多的细节和CEP伪代码来给出更具体的建议。