Hi Flink community,
I have a custom source that emits an user-defined data type, BaseEvent. The
following code works fine when BaseEvent is not POJO.
But, when I changed it to POJO by adding a default constructor, I'm getting
"Buffer Pool is destroyed" runtime exception on the Collect method.
Thank you. Forgot to mention that the error occurred when I was testing my
code in Intellij.
From: zhijiang [mailto:wangzhijiang...@aliyun.com]
Sent: Friday, December 21, 2018 4:40 PM
To: user@flink.apache.org; Chan, Shuang (PWTB 291)
Subject: 回复：buffer pool is destroyed
Hi Shuang,
Normally
