【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