1.概述

FLink 如果watermark水印时间超出今天会是什么问题呢

测试如下

/**
     * 测试点：测试事件时间，如果中途突然来了一个时间是未来时间 会导致什么？
     * 当前时间
     *   2022-01-06 13:29:19
     * 然后输出能触发的时间
     * 1641446787000  2022-01-06 13:26:27
     * 1641446847000
     * 1641446907000  2022-01-06 13:28:27
     *
     * 假设突然来了未来时间
     * 1641533307000  2022-01-07 13:28:27
     * 1641533427000
     * 1641533727000
     * 1641446849000
     *
     * 现在看看触发结果
     *
     * (1641446787000,1)  2022-01-06 13:26:27
     * (1641446847000,1)
     * (1641446907000,1)  2022-01-06 13:28:27
     * (1641533307000,1)  2022-01-07 13:28:27
     * (1641533427000,1)  2022-01-07 13:30:27
     * 这里后来输入 2022