Re: What metrics can I see the root cause of "Buffer pool is destroyed" message?

://felipeogutierrez.blogspot.com <https://felipeogutierrez.blogspot.com>* On Wed, Nov 6, 2019 at 4:30 PM Zhijiang wrote: > Hi Felipe, > > "Buffer pool is destroyed" is mainly caused by canceling task. That means > there are other tasks failure which would trigger canceling

Re: What metrics can I see the root cause of "Buffer pool is destroyed" message?

Hi Felipe, "Buffer pool is destroyed" is mainly caused by canceling task. That means there are other tasks failure which would trigger canceling all the topology tasks by job master. So if you want to find the root cause, it is proper to check the job master log to find the first fai

What metrics can I see the root cause of "Buffer pool is destroyed" message?

here is my stack trace: java.lang.RuntimeException: Buffer pool is destroyed. at org.apache.flink.streaming.runtime.io.RecordWriterOutput.pushToRecordWriter(RecordWriterOutput.java:110) at org.apache.flink.streaming.runtime.io.RecordWriterOutput.collect(RecordWriterOutput.java:8

RE: 回复：buffer pool is destroyed

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

回复：buffer pool is destroyed

-- 发件人：Chan, Shuang 发送时间：2018年12月21日(星期五) 11:12 收件人：user@flink.apache.org 主　题：buffer pool is destroyed 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

buffer pool is destroyed

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

Re: Flink 1.6 Job fails with IllegalStateException: Buffer pool is destroyed.

hijiang999) > 主 题：Re: Flink 1.6 Job fails with IllegalStateException: Buffer pool is > destroyed. > > > I have checked logs from yarn nodemanagers, and there are no killing > action record. There are no job canceling record in jobmanager's log either. > > Here are jo

Re: Flink 1.6 Job fails with IllegalStateException: Buffer pool is destroyed.

question, but I don't know if the answer is valid.[2] [1]: https://issues.apache.org/jira/browse/FLINK-9054 [2]: Https://stackoverflow.com/questions/48276484/flink-throwing-java-lang-runtimeexception-buffer-pool-is-destroyed Thanks, vino. 杨力 于2018年9月7日周五 下午1:09写道： > Hi all, > I am enc

回复：Flink 1.6 Job fails with IllegalStateException: Buffer pool is destroyed.

, Zhijiang -- 发件人：杨力 发送时间：2018年9月7日(星期五) 13:09 收件人：user 主　题：Flink 1.6 Job fails with IllegalStateException: Buffer pool is destroyed. Hi all, I am encountering a weird problem when running flink 1.6 in yarn per-job clusters. The job

Flink 1.6 Job fails with IllegalStateException: Buffer pool is destroyed.

Hi all, I am encountering a weird problem when running flink 1.6 in yarn per-job clusters. The job fails in about half an hour after it starts. Related logs is attached as an imange. This piece of log comes from one of the taskmanagers. There are not any other related log lines. No ERROR-level log