zhijiang created FLINK-14498:
--------------------------------
Summary: 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
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)
