Flink实时统计 结果波动时大时小

[flink2021]

我用Zepplin 上面提交作业统计我们的订单数 结果放入mysql，数据源为kafka
，发现在kafka中数据有积压时，然后去查询结果表的数据，发现有时候时大时小，（连续的几个查询）有时是100w，下一秒可能就是50w，这里是什么原因呢？PS.flink计算的逻辑有点复杂



--
Sent from: http://apache-flink.147419.n8.nabble.com/