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中的times

>>阅读原文<<