[ https://issues.apache.org/jira/browse/FLINK-14498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
zhijiang updated FLINK-14498: ----------------------------- Parent: FLINK-14551 Issue Type: Sub-task (was: Task) > Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool > ------------------------------------------------------------------------------ > > Key: FLINK-14498 > URL: https://issues.apache.org/jira/browse/FLINK-14498 > Project: Flink > Issue Type: Sub-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)