【Flink】Flink 基于事件序列最大值 AssignerWithPeriodicWatermarks

1.案例

	@Test
    public void mainTest() throws Exception {
        //定义socket的端口号
        int port = 9010;
        //获取运行环境
        StreamExecutionEnvironment env