Caused by: java.lang.RuntimeException: Record has Long.MIN_VALUE timestamp (= no timestamp marker). Is the time characteristic set to 'ProcessingTime', or did you forget to call 'DataStream.assignTimestampsAndWatermarks(...)'?
原因:
在使用老版的窗口时,未指定时间语义,导致报错。
解决方案:
在声明 Flink 环境时，设置时间语义
//需要设置时间语义
env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime);