watermark watermark的作用 就是延迟触发窗口，让乱序到达的元素依然能够落在正确的窗口内。为啥能实现这个效果，一直通过公式更新watermark,如果乱序到的元素就不能更新watermark,相当于就是延迟触发计算操作。触发时间 watermark 大于窗口的最大值allowedLateness 允许迟到的时间，到底啥时到的元素算迟到元素,如果元素的窗口满足下面这个公式，那这个窗

MaxOutOfOrderness 和 Allowedlateness 都是为了对乱序数据进行处理，但是经常会混淆着两个概念，需要进行一些区分。 MaxOutOfOrderness source.map(...//省略不必要代码)       // 定义 watermark       .assignTimestampsAndWatermarks(             // 设