下游的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!