[
https://issues.apache.org/jira/browse/FLINK-20013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227265#comment-17227265
]
Nicholas Jiang edited comment on FLINK-20013 at 11/6/20, 11:12 AM:
-------------------------------------------------------------------
[~zhuzh], with failed or canceled task, the current BufferConsumer in
BoundedBlockingSubpartition isn't closed which causes network buffer leak.
Therefore the current BufferConsumer should be closed when task is failed or
canceled.
cc [~zjwang] [~pnowojski]
was (Author: nicholasjiang):
[~zhuzh], when task is failed or canceled, the current BufferConsumer in
BoundedBlockingSubpartition doesn't close which causes network buffer leak.
Therefore the current BufferConsumer should be closed wheen task is failed or
canceled.
cc [~zjwang] [~pnowojski]
> BoundedBlockingSubpartition may leak network buffer if task is failed or
> canceled
> ---------------------------------------------------------------------------------
>
> Key: FLINK-20013
> URL: https://issues.apache.org/jira/browse/FLINK-20013
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Network
> Reporter: Yingjie Cao
> Assignee: Nicholas Jiang
> Priority: Major
> Fix For: 1.12.0
>
>
> BoundedBlockingSubpartition may leak network buffer if task is failed or
> canceled. We need to recycle the current BufferConsumer when task is failed
> or canceled.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
