请教一下,KeyedCoProcessFunction比较特殊,有两个输入,对应两个ProcessElement方法。 问题1: 如果在这两个Process方法中都对同一个MapState进行修改,是否会存在资源竞争的关系? 还是这两个方法是顺序执行的?
问题2: 虽然有不同的key,但函数只有一个实例,其中的MapState应该也是一个实例,那么不同key下的 Process过程是并发执行的还是顺序执行的,会竞争MapState资源吗? *来自志愿者整理的flink邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。