Re: 当数据源产生的速度过快时使用AscendingTimestampExtractor并没有忽略非递增的事件时间数据

我想明白了，AscendingTimestampExtractor产生的水印是周期水印，当数据源速率过快时，水印还没来得及发送，后面的数据已经进入到算子当中了，所以造成了非递增事件也会被包含在算子中。。在测试环境下，如果换成Punctuated
Watermarks对每个事件发送水印，就没问题了




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

回复