开发者社区> 问答> 正文

KeyedCoProcessFunction中的状态数据是否存在资源竞争呢?

请教一下,KeyedCoProcessFunction比较特殊,有两个输入,对应两个ProcessElement方法。 问题1: 如果在这两个Process方法中都对同一个MapState进行修改,是否会存在资源竞争的关系? 还是这两个方法是顺序执行的?

问题2: 虽然有不同的key,但函数只有一个实例,其中的MapState应该也是一个实例,那么不同key下的 Process过程是并发执行的还是顺序执行的,会竞争MapState资源吗? *来自志愿者整理的flink邮件归档

展开
收起
游客sadna6pkvqnz6 2021-12-07 17:14:40 871 0
1 条回答
写回答
取消 提交回答
  • 问题1&2 都不存在多线程的问题。Flink底层来保证这些方法都是在同一个线程串行执行的。*来自志愿者整理的flink

    2021-12-07 20:35:14
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
《阿里云资源保障服务,让您从容应对资源波峰》 立即下载
运用新技术解决有状态应用的冷热迁移挑战 迁移策略+新容器运行时 立即下载
用户态高速块缓存方案 立即下载

相关实验场景

更多