FlinkFlink 周期性 watermark 的 传播 AssignerWithPeriodicWatermarks

Posted 2021-09-08 九师兄

文章目录

• 1.概述
• 2.ProcessingTimeServiceImpl
• • 2.2 onPeriodicEmit
• 3. watermark最小

1.概述

今天想了解一下watermark在flink源码中是如何传播的。写了一个测试类如下

@Test
    public void mainTest1() throws