回复：FLINK SQL 消费kafka消息乱序问题

Sun, 29 Nov 2020 16:50:19 -0800 

可能是有退款呢，我也做过类似的统计



---原始邮件---
发件人: 
"user-zh-return-9443-374060171=qq.com"<[email protected]&gt;
发送时间: 2020年11月30日(周一) 上午7:37
收件人: "user-zh"<[email protected]&gt;;
主题: Re: FLINK SQL 消费kafka消息乱序问题


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

发自我的iPhone

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

回复