这个节点的下游节点挂了,具体原因要看下游节点的log。
> 在 2019年4月9日,下午2:11,Yang Peng 写道:
>
> 一般情况下是内存太小了,导致的问题
>
> 应聘程序员 北京邮电大学 <13341000...@163.com> 于2019年4月9日周二 下午1:37写道:
>
>> hi, 大家好!
>>今天运行flink时抛出了Buffer pool is
>> destroyed异常,数据源是kafka;消费前kafka队列中堆积了8G左右的数据。详细报错如下:
>>
>>
>>
>> org.apache.flink.streaming.r
一般情况下是内存太小了,导致的问题
应聘程序员 北京邮电大学 <13341000...@163.com> 于2019年4月9日周二 下午1:37写道:
> hi, 大家好!
> 今天运行flink时抛出了Buffer pool is
> destroyed异常,数据源是kafka;消费前kafka队列中堆积了8G左右的数据。详细报错如下:
>
>
>
> org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException:
> Could not forward element to next
hi, 大家好!
今天运行flink时抛出了Buffer pool is
destroyed异常,数据源是kafka;消费前kafka队列中堆积了8G左右的数据。详细报错如下:
org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException:
Could not forward element to next operator
at
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOu