This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from d505e6e [FLINK-9925] Rework Client to encapsulate concurrency of
single connection
add ee6c887 [hotfix] Print the test parameters for
UnalignedCheckpointTestBase to help debugging when the case is stuck
add 48a384d [FLINK-23466][network] Fix the bug that buffer listeners may
not be notified when recycling buffers
add c91837e [hotfix][refactor] Remove BufferListener#NotificationResult
to simplify the code
No new revisions were added by this update.
Summary of changes:
.../runtime/io/network/buffer/BufferListener.java | 42 ++------------
.../runtime/io/network/buffer/LocalBufferPool.java | 24 ++------
.../network/partition/consumer/BufferManager.java | 58 ++++++++++----------
.../io/network/buffer/LocalBufferPoolTest.java | 64 +++++++++-------------
.../partition/consumer/RemoteInputChannelTest.java | 26 ++++-----
.../checkpointing/UnalignedCheckpointTestBase.java | 8 +++
6 files changed, 83 insertions(+), 139 deletions(-)
