flink窗口的时间类型报错

报错问题:

找到原因:

在使用旧版的窗口时,未指定时间语义,导致报错.

解决办法:

//需要设置时间语义
        env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime);
           

这个也是冥思苦想了两三天才解决的