问题可能出在被省略的部分，检查一下最底层的 caused by Thanks, Biao /'bɪ.aʊ/
On Sun, 29 Sep 2019 at 13:17, <18612537...@163.com> wrote: > 我看过这个我不是这个问题，作业没有设置水印，作业可以正常运行，最近可能是运行一天多会报这个异常 > > 发自我的 iPhone > > > 在 2019年9月29日，上午11:49，Wesley Peng <wesph...@gmail.com> 写道： > > > > Hello, > > > > May this article match your issue? > > https://blog.csdn.net/qq_41910230/article/details/90411237 > > > > regards. > > > >> On Sun, Sep 29, 2019 at 10:33 AM allan <18612537...@163.com> wrote: > >> > >> Hi， > >> > >> 最近发现作业一直在报错，我的窗口是一分钟的窗口。这是什么原因，谁能帮助一下？flink版本1.6 ,错误如下： > >> > >> > >> > >> > TimerException{org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException: > >> Could not forward element to next operator} > >> > >> at > >> > org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService$TriggerTask.run(SystemProcessingTimeService.java:288) > >> > >> at > >> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > >> > >> at java.util.concurrent.FutureTask.run(FutureTask.java:266) > >> > >> at > >> > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) > >> > >> at > >> > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) > >> > >> at > >> > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > >> > >> at > >> > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > >> > >> at java.lang.Thread.run(Thread.java:748) > >> > >> Caused by: > >> > org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException: > >> Could not forward element to next operator > >> > >> at org.apache.flink.streaming. > >> > >> > >> > runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:596) > >> > >> at > >> > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:554) > >> > >> at > >> > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:534) > >> > >> at > >> > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:689) > > >
