Could not forward element to next operator

Hi， 最近发现作业一直在报错，我的窗口是一分钟的窗口。这是什么原因，谁能帮助一下？错误如下： TimerException{org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException: Could not forward element to next operator} at

map不能返回null值吗

Hi, 发现了一个问题，就是在调用map函数后，返回的null值，map的返回值为tuple2，在下一步filter过滤null值是，作业报异常。 java.lang.NullPointerException at org.apache.flink.api.java.typeutils.runtime.TupleSerializer.copy(TupleSerializer.java:104) at