flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 18612537...@163.com
Subject Re: Could not forward element to next operator
Date Sun, 29 Sep 2019 05:10:54 GMT
我看过这个我不是这个问题,作业没有设置水印,作业可以正常运行,最近可能是运行一天多会报这个异常

发自我的 iPhone

> 在 2019年9月29日,上午11:49,Wesley Peng <wesphang@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 <18612537914@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)



Mime
View raw message