flink.streaming.runtime.tasks.ExceptionInChainedOperatorException: Could not forward element to next

Error executing map action org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException: Could not forward element to next operator at

今天在跑一个flink程序的时候，一直报这个错

最后发现是配置的Watermark中的timestamp有问题，需要指定一下你的输入数据中时间的格式，比如我的是"2018-02-03 21:00:00"，格式应该配置成"yyyy-MM-dd HH:mm:ss"

2022-12-23
2021-08-21
2021-09-12
2021-08-17
2021-04-03
2021-09-17
2021-06-18
2021-09-01