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
i,
> >>
> >> 最近发现作业一直在报错,我的窗口是一分钟的窗口。这是什么原因,谁能帮助一下?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.t