flink中kafkasource并行度大于kafka分区数设置并行度问题

it2025-01-26  14

面试题

kafka分区数5,flinksource并行度设置6。如何设置水位线才能使下游窗口触发计算!

回答

flink官方文档 flink通过一个idel标志位标记channel,所以下游知道哪些channel是没有event的,最后去watermark就不会管那个有idle标记的空channel

最新回复(0)