Flink 报错 Caused by: java.lang.RuntimeException: Record has Long.MIN

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);