Flink报错Could not forward element to next operator Buffer pool is destroyed

Posted 九师兄

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink报错Could not forward element to next operator Buffer pool is destroyed相关的知识，希望对你有一定的参考价值。

1.美图

2.概述

报错原因

这个异常一般是数据源端，出现脏数据，存在null值导致的。

参考：https://stackoverflow.com/questions/53878750/buffer-pool-is-destroyed-on-pojo-type

参考：【Flink】Buffer pool is destroyed

以上是关于Flink报错Could not forward element to next operator Buffer pool is destroyed的主要内容，如果未能解决你的问题，请参考以下文章