问题:
今天写Flink批量向mysql写数据的时候,个数窗口可以成功,但是按照时间窗口存在问题
排查:
经过排查,发现是时间有问题,写了按照事件时间处理
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
但是写入的数据,没有时间戳,因此一直在产生数据,但是没写入操作。
最终改成处理时间解决完毕
env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime);
总结:Flink时间水印
1.EventTime
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
参考:https://blog.csdn.net/u012348345/article/details/80199467
2.IngestTime
3.ProcessingTime
不设置Time 类型,默认是processingTime。