You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "zhijiang (Jira)" <ji...@apache.org> on 2019/10/23 02:43:00 UTC

[jira] [Created] (FLINK-14498) Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool

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)