This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
from 74097409e7a [FLINK-29234] JobMasterServiceLeadershipRunner#closeAsync
has a lock with an excessive range
add 6b565055beb [FLINK-28695][network] Fix the bug of old netty client
isn't closed when netty server closes channel and no input channel
No new revisions were added by this update.
Summary of changes:
.../CreditBasedPartitionRequestClientHandler.java | 22 +++----
.../netty/PartitionRequestClientFactoryTest.java | 76 ++++++++++++++++++++++
2 files changed, 85 insertions(+), 13 deletions(-)
