flink sql 当一个env下多个insert语句共享一个view时出问题

当前使用版本flink 1.10.0，使用blink planner，假如有如下代码：

tEnv.createTemporaryView("b", tEnv.sqlQuery("select * from a")); tEnv.sqlUpdate("insert into c select * from b where b.con1 = '1'"); tEnv.sqlUpdate("insert into d select * from b where b.con1 = '2'");

其中a是kafka表，connector属性为： 'connector.properties.group.id' = 'testGroup', 'connector.startup-mode' = 'group-offsets'

疑问是该应用运行时c、d消费a表，a表group 'testGroup' offset的提交会不会受到影响，还是a表中同一条记录会流向2个不同的分支？

来自志愿者整理的flink邮件归档来自志愿者整理的FLINK邮件归档