求助帖: 流join场景可能出现的重复计算

实际场景还是有点复杂的, 便于理解 我简化成这样的, 简化后的这个, 没有实际的代码, 抱歉

大致 写一下 也就是这样了

select sum(score)

from

student t1 inner join score t2 on t1.student_id = t2.std_id

where

t1.student_id = 11

然后

String sql = ↑;

Table t = tEnv.sqlQuery(sql);

DataStream<Integer> stream1 = tEnv.toAppendStream(t, Integer.class);

stream1.keyBy("xxxx").sum("xxxx");

这样的一个sql, 在student表插入一个数据, score表插入2个数据后, 会执行一次计算出一个结果97 + 98

update 学生表的name后, 一个新事件进入student的流, 还会触发一次计算, 得到97 + 98

因为可能有新的成绩插入, 所以对 stream1进行sum操作, 导致 97和98 都被重复计算了一次*来自志愿者整理的FLINK邮件归档