1.Record has Long.MIN_VALUE timestamp (= no timestamp marker). Is the time characteristic set to 'ProcessingTime', or did you forget to call 'DataStream.assignTimestampsAndWatermarks(...)'?

解決辦法：

? ??

時間窗口事件選擇此方法，Time導(dǎo)包也需要注意，不是common.api的那個

總結(jié)

以上是生活随笔為你收集整理的Flink1.12.0使用过程中遇到的异常的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。