|
apache
/
flink
|
|
master
|
35 hrs, 45 mins, 20 secs
|
kevin.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.
|
|