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

Posted 2022-08-31 九师兄

1.美图

2.概述

报错原因

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

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

参考：【Flink】Buffer pool is destroyed