ava: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
Hi,
最近发现作业一直在报错,我的窗口是一分钟的窗口。这是什么原因,谁能帮助一下?错误如下:
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
0230/article/details/90411237
>> >
>> > regards.
>> >
>> >> On Sun, Sep 29, 2019 at 10:33 AM allan <18612537...@163.com> wrote:
>> >>
>> >> Hi,
>> >>
>> >> 最近发现作业一直在报错,我的窗口是一分钟的窗口。这是什
gt; Hi,
> >>
> >> 最近发现作业一直在报错,我的窗口是一分钟的窗口。这是什么原因,谁能帮助一下?flink版本1.6 ,错误如下:
> >>
> >>
> >>
> >>
> TimerException{org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException:
> >> Could not forward element to next operator}
> >>
> >>
:33 AM allan <18612537...@163.com> wrote:
>>
>> Hi,
>>
>> 最近发现作业一直在报错,我的窗口是一分钟的窗口。这是什么原因,谁能帮助一下?flink版本1.6 ,错误如下:
>>
>>
>>
>> TimerException{org.apache.flink.streaming.runtime.tasks.ExceptionInC
t;
>
> 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)
>
&g
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