This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from dcd9295 [FLINK-10706][web]: Rework Flink Web Dashboard
new 232426a [hotfix][tests] Simplify TaskExecutor creation
new 0bbfdd9 [hotfix][tests] Simplify TaskManagerServices creation
new dda824f [hotfix][runtime] Move hostname retrieval logic into separate
methods
new 5b2ca7f [hotfix][network] Refactor
NetworkEnvironmentConfigurationBuilder into NetworkEnvironmentBuilder
new daa51b5 [FLINK-12213][network] Move network metrics setup into
NetworkEnvironment
The 16397 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../runtime/io/network/NetworkEnvironment.java | 24 ++-
.../flink/runtime/metrics/util/MetricUtils.java | 25 +--
.../runtime/taskexecutor/TaskManagerRunner.java | 14 +-
.../runtime/taskexecutor/TaskManagerServices.java | 9 +-
.../NetworkEnvironmentConfigurationBuilder.java | 95 ----------
.../runtime/taskmanager/TaskManagerLocation.java | 73 +++++---
.../io/network/NetworkEnvironmentBuilder.java | 115 ++++++++++++
.../runtime/io/network/NetworkEnvironmentTest.java | 11 +-
.../io/network/partition/ResultPartitionTest.java | 8 +-
.../partition/consumer/SingleInputGateTest.java | 12 +-
.../TaskExecutorLocalStateStoresManagerTest.java | 43 ++---
.../runtime/taskexecutor/TaskExecutorTest.java | 196 +++++----------------
.../TaskSubmissionTestEnvironment.java | 8 +-
.../StreamNetworkBenchmarkEnvironment.java | 6 +-
14 files changed, 285 insertions(+), 354 deletions(-)
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/NetworkEnvironmentConfigurationBuilder.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/NetworkEnvironmentBuilder.java
