Re: FLINK SQL 消费kafka消息乱序问题

Sun, 29 Nov 2020 15:37:34 -0800 

确定是消息乱序吗？是不是计算的数据类型有问题？

发自我的iPhone

> 在 2020年11月27日，下午5:44，bulterman <[email protected]> 写道：
> 
> Hi All,
> kafka消息里有一个随时间递增的“成交额”字段，写了一个UDAF统计累加当前成交额与上一条数据的成交额的差值，发现差值有出现负数的情况  
> 用工具看topic里的消息是有序的，分区数为1。flink版本1.11.2

回复