You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by cs <58...@qq.com.INVALID> on 2021/08/30 14:26:37 UTC

flink keyby问题

flink在keyby后，如何知道某个key落在下游的哪个task中？有什么公式算出来落在下游哪个task的id号吗

回复：flink keyby问题

Posted by JasonLee <17...@163.com>.

hi


可以看下 KeyGroupStreamPartitioner#selectChannel 这个方法.


Best
JasonLee
在2021年8月30日 22:34，cs<58...@qq.com.INVALID> 写道：
flink在keyby后，如何知道某个key落在下游的哪个task中？有什么公式算出来落在下游哪个task的id号吗