Hi,

问题1&2 都不存在多线程的问题。Flink底层来保证这些方法都是在同一个线程串行执行的。

shizk233 <[email protected]> 于2020年8月20日周四 下午2:22写道:

> Hi all,
>
> 请教一下,KeyedCoProcessFunction比较特殊,有两个输入,对应两个ProcessElement方法。
> 问题1:
> 如果在这两个Process方法中都对同一个MapState进行修改,是否会存在资源竞争的关系?
> 还是这两个方法是顺序执行的?
>
> 问题2:
> 虽然有不同的key,但函数只有一个实例,其中的MapState应该也是一个实例,那么不同key下的
> Process过程是并发执行的还是顺序执行的,会竞争MapState资源吗?
>


-- 

Best,
Benchao Li

回复