This is an automated email from the ASF dual-hosted git repository.
mbalassi pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from c23a3002b83 [FLINK-30863][state/changelog] Register local recovery
files of changelog before notifyCheckpointComplete()
add de01f021bdf [FLINK-32811][runtime] Add port range support for
"taskmanager.data.bind-port"
No new revisions were added by this update.
Summary of changes:
.../generated/all_taskmanager_section.html | 6 ++
.../generated/common_host_port_section.html | 6 ++
.../netty_shuffle_environment_configuration.html | 4 +-
.../NettyShuffleEnvironmentOptions.java | 12 +++-
.../main/java/org/apache/flink/util/NetUtils.java | 18 ++++--
.../java/org/apache/flink/util/NetUtilsTest.java | 34 +++++++++++
.../runtime/io/network/netty/NettyClient.java | 6 +-
.../runtime/io/network/netty/NettyConfig.java | 25 +++++---
.../runtime/io/network/netty/NettyServer.java | 45 ++++++++++++--
.../runtime/taskexecutor/TaskManagerServices.java | 4 ++
.../NettyShuffleEnvironmentConfiguration.java | 45 +++++++-------
.../org/apache/flink/runtime/util/PortRange.java | 61 +++++++++++++++++++
.../io/network/netty/NettyClientServerSslTest.java | 30 ++-------
.../netty/NettyServerFromPortRangeTest.java | 71 ++++++++++++++++++++++
.../runtime/io/network/netty/NettyTestUtil.java | 23 ++++++-
.../util/{HardwareTest.java => PortRangeTest.java} | 34 +++++------
16 files changed, 326 insertions(+), 98 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/util/PortRange.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/NettyServerFromPortRangeTest.java
copy
flink-runtime/src/test/java/org/apache/flink/runtime/util/{HardwareTest.java =>
PortRangeTest.java} (56%)
