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 JasonLee <17...@163.com> on 2021/08/30 14:42:31 UTC
回复:flink keyby问题
hi
可以看下 KeyGroupStreamPartitioner#selectChannel 这个方法.
Best
JasonLee
在2021年8月30日 22:34,cs<58...@qq.com.INVALID> 写道:
flink在keyby后,如何知道某个key落在下游的哪个task中?有什么公式算出来落在下游哪个task的id号吗