currentMaxTimestamp 只是当前数据流里面最大,但不一定是全部的最大。
当数据出现延迟,或者多流的情况下,lastEmittedWatermark 不一定会比 currentMaxTimestamp 小



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

回复