You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gu...@apache.org on 2022/02/16 06:09:34 UTC
[flink] branch master updated (3106f14 -> 5be7d48)
This is an automated email from the ASF dual-hosted git repository.
guoyangze pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 3106f14 [hotfix][tests][connector/kafka] Disable KafkaSink metric tests until FLINK-26126 has been fixed
add c0cca2e [hotfix][network] Remove the deduplication for CancelPartitionRequest.
add 5be7d48 [FLINK-15455][network] Enabled tcp connection reuse across multi jobs.
No new revisions were added by this update.
Summary of changes:
.../generated/all_taskmanager_network_section.html | 6 +
.../netty_shuffle_environment_configuration.html | 6 +
.../NettyShuffleEnvironmentOptions.java | 26 +++++
.../io/network/NettyShuffleServiceFactory.java | 3 +-
.../runtime/io/network/NetworkClientHandler.java | 7 ++
.../io/network/netty/ConnectionErrorMessage.java | 27 ++---
.../CreditBasedPartitionRequestClientHandler.java | 21 ++--
.../io/network/netty/NettyConnectionManager.java | 8 +-
.../network/netty/NettyPartitionRequestClient.java | 72 +++++++++---
.../netty/PartitionRequestClientFactory.java | 24 ++--
.../NettyShuffleEnvironmentConfiguration.java | 24 +++-
.../util/AtomicDisposableReferenceCounter.java | 106 -----------------
.../io/network/NettyShuffleEnvironmentBuilder.java | 11 +-
.../network/netty/NettyConnectionManagerTest.java | 2 +-
.../netty/NettyPartitionRequestClientTest.java | 56 ++++++++-
.../netty/PartitionRequestClientFactoryTest.java | 31 +++--
.../util/AtomicDisposableReferenceCounterTest.java | 127 ---------------------
17 files changed, 248 insertions(+), 309 deletions(-)
copy flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.less => flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/ConnectionErrorMessage.java (72%)
delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/util/AtomicDisposableReferenceCounter.java
delete mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/util/AtomicDisposableReferenceCounterTest.java