You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by flink2021 <ye...@163.com> on 2021/02/16 07:30:13 UTC

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

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



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