[
https://issues.apache.org/jira/browse/FLINK-14498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960766#comment-16960766
]
Jiayi Liao commented on FLINK-14498:
------------------------------------
[~kevin.cyj] Thanks for you explaination :).
> 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)
