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
