【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