[
https://issues.apache.org/jira/browse/FLINK-14498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960764#comment-16960764
]
Yingjie Cao commented on FLINK-14498:
-------------------------------------
[~wind_ljy] The PR is based on another PR
[https://github.com/apache/flink/pull/9905] which has not been merged yet. Only
the last commit is relevant to the this jira. I will do rebase once the
dependent PR is merged.
> Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool
> ------------------------------------------------------------------------------
>
> Key: FLINK-14498
> URL: https://issues.apache.org/jira/browse/FLINK-14498
> Project: Flink
> Issue Type: Task
> Components: Runtime / Network
> Reporter: zhijiang
> Assignee: Yingjie Cao
> Priority: Minor
> Labels: pull-request-available
> Fix For: 1.10.0
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> If the LocalBufferPool can not request available buffer from
> NetworkBufferPool, it would wait for 2 seconds before trying to request again
> in a loop way. Therefore it would bring some delays in practice.
> To improve this interaction, we could introduce NetworkBufferPool#isAvailable
> to return a future which would be monitored by LocalBufferPool. Then once
> there are available buffers in NetworkBufferPool, it would complete this
> future to notify LocalBufferPool immediately.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
