下游的process算子数取决于并行度,parallelism。而不是你的数据key有多少。

Peihui He <peihu...@gmail.com> 于2022年5月29日周日 11:55写道:
>
> Hi, all
>
> 请教下大家,flink key by 后 使用process 来处理数据。现在有个问题:
> 当key不限量的情况下,比如uuid,这种情况下,下游都会创建一个process 对象来处理数据不?
> 如果这样的话,是不是没多久就会oom呢?
>
> 大家有熟悉这块相关flink 源码不?求指导,想自己观察下。
>
> Best Regards!

回复