apache

/

flink

branch iconmaster

arrow to build time
clock icon2 hrs, 47 mins, 20 secs

kevin.cyj avatarkevin.cyj

[FLINK-14603][runtime] Notify the potential buffer consumer if the size of LocalBufferPool has been expanded.

Currently, when the size of LocalBufferPool is expanded by LocalBufferPool#setNumBuffers and there are segments
available in the global NetworkBufferPool, we may fail to notify the potential buffer consumer which is waiting
for the LocalBufferPool to be available. This commit fixes the problem by completing the previous uncompleted
available future when the size of LocalBufferPool is expanded.

Reply via email to