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 smq <37...@qq.com> on 2020/11/30 00:49:57 UTC
回复：FLINK SQL 消费kafka消息乱序问题
可能是有退款呢，我也做过类似的统计
---原始邮件---
发件人: "user-zh-return-9443-374060171=qq.com"<user-zh-return-9443-374060171=qq.com@flink.apache.org>
发送时间: 2020年11月30日(周一) 上午7:37
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: Re: FLINK SQL 消费kafka消息乱序问题
确定是消息乱序吗？是不是计算的数据类型有问题？
发自我的iPhone
> 在 2020年11月27日，下午5:44，bulterman <15618338059@163.com> 写道：
>
> Hi All,
> kafka消息里有一个随时间递增的“成交额”字段，写了一个UDAF统计累加当前成交额与上一条数据的成交额的差值，发现差值有出现负数的情况
> 用工具看topic里的消息是有序的，分区数为1。flink版本1.11.2