Hi. 会根据 key 的 hash 值分配到固定个数的 keygroup 之中的。简单来说，跟HashMap<K, List<V>> 有点相似。金竹老师有一篇文章详细解释了[1]。
如果想看实现的话，可以从 KeyGroupStreamPartitioner 入手来看看 Table 层是怎么做的。 Best, Shengkai [1] https://developer.aliyun.com/article/667562 Peihui He <peihu...@gmail.com> 于2022年5月29日周日 11:55写道： > Hi, all > > 请教下大家，flink key by 后 使用process 来处理数据。现在有个问题： > 当key不限量的情况下，比如uuid，这种情况下，下游都会创建一个process 对象来处理数据不？ > 如果这样的话，是不是没多久就会oom呢？ > > 大家有熟悉这块相关flink 源码不？求指导，想自己观察下。 > > Best Regards! >
