有多少个并发度,就有多少个process对象,因此就这个对象而言,不会出现OOM的情况。但是,如果你每个key都需要存state,在key无限量的情况下,会导致state膨胀的很大,可能会出现OOM的情况。
在 2022-05-29 11:54:38,"Peihui He" <peihu...@gmail.com> 写道:
>Hi, all
>
>请教下大家,flink key by 后 使用process 来处理数据。现在有个问题:
>当key不限量的情况下,比如uuid,这种情况下,下游都会创建一个process 对象来处理数据不?
>如果这样的话,是不是没多久就会oom呢?
>
>大家有熟悉这块相关flink 源码不?求指导,想自己观察下。
>
>Best Regards!

回复