This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 774ecea [FLINK-12795][table-planner-blink] Extracted creation &
configuration of FrameworkConfig & RelBuilder to separate class in blink planner
new c1c6d1f [hotfix][network] Add NetworkEnviroment.fromConfiguration
factory method
new 6349db7 [FLINK-11392][network] Introduce ShuffleEnvironment interface
new c104daf [FLINK-11392][network] Rename NetworkEnviroment to
NettyShuffleEnviroment
The 3 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:
.../flink/addons/hbase/HBaseConnectorITCase.java | 4 +-
.../flink/configuration/ConfigConstants.java | 12 +-
...ns.java => NettyShuffleEnvironmentOptions.java} | 4 +-
...TaskManagerHeapSizeCalculationJavaBashTest.java | 28 +-
...vironment.java => NettyShuffleEnvironment.java} | 109 ++++---
.../network/api/writer/ResultPartitionWriter.java | 12 +-
.../io/network/buffer/NetworkBufferPool.java | 14 +-
.../runtime/io/network/netty/NettyConfig.java | 18 +-
.../network/partition/ResultPartitionFactory.java | 3 +-
.../partition/consumer/SingleInputGateFactory.java | 7 +-
.../flink/runtime/shuffle/ShuffleEnvironment.java | 166 ++++++++++
.../runtime/shuffle/ShuffleEnvironmentContext.java | 94 ++++++
.../flink/runtime/taskexecutor/TaskExecutor.java | 15 +-
.../runtime/taskexecutor/TaskManagerRunner.java | 9 +-
.../runtime/taskexecutor/TaskManagerServices.java | 73 +++--
.../TaskManagerServicesConfiguration.java | 90 ++++--
...a => NettyShuffleEnvironmentConfiguration.java} | 145 ++++-----
.../org/apache/flink/runtime/taskmanager/Task.java | 12 +-
.../runtime/util/ConfigurationParserUtils.java | 29 ++
.../ContaineredTaskManagerParametersTest.java | 4 +-
...er.java => NettyShuffleEnvironmentBuilder.java} | 38 +--
...tTest.java => NettyShuffleEnvironmentTest.java} | 21 +-
.../network/netty/NettyConnectionManagerTest.java | 8 +-
.../PartialConsumePipelinedResultTest.java | 4 +-
.../io/network/partition/PartitionTestUtils.java | 6 +-
.../network/partition/ResultPartitionBuilder.java | 4 +-
.../io/network/partition/ResultPartitionTest.java | 8 +-
.../partition/consumer/InputChannelBuilder.java | 4 +-
.../partition/consumer/InputGateTestBase.java | 4 +-
.../partition/consumer/SingleInputGateBuilder.java | 8 +-
.../partition/consumer/SingleInputGateTest.java | 40 +--
.../TaskExecutorLocalStateStoresManagerTest.java | 12 +-
.../NettyShuffleEnvironmentConfigurationTest.java | 334 +++++++++++++++++++++
.../taskexecutor/NetworkBufferCalculationTest.java | 28 +-
.../NetworkEnvironmentConfigurationTest.java | 301 -------------------
.../taskexecutor/TaskExecutorSubmissionTest.java | 30 +-
.../runtime/taskexecutor/TaskExecutorTest.java | 30 +-
.../taskexecutor/TaskManagerRunnerStartupTest.java | 4 +-
.../taskexecutor/TaskManagerServicesBuilder.java | 12 +-
.../TaskManagerServicesConfigurationTest.java | 64 ----
.../TaskSubmissionTestEnvironment.java | 58 ++--
.../runtime/taskmanager/TaskAsyncCallTest.java | 16 +-
.../TaskCancelAsyncProducerConsumerITCase.java | 4 +-
.../apache/flink/runtime/taskmanager/TaskTest.java | 29 +-
.../runtime/util/JvmExitOnFatalErrorTest.java | 8 +-
.../streaming/runtime/io/InputProcessorUtil.java | 4 +-
.../StreamNetworkBenchmarkEnvironment.java | 27 +-
.../StreamNetworkThroughputBenchmarkTest.java | 8 +-
.../tasks/InterruptSensitiveRestoreTest.java | 8 +-
.../runtime/tasks/StreamTaskTerminationTest.java | 8 +-
.../streaming/runtime/tasks/StreamTaskTest.java | 8 +-
.../runtime/tasks/SynchronousCheckpointITCase.java | 8 +-
.../tasks/TaskCheckpointingBehaviourTest.java | 8 +-
.../flink/test/cancelling/CancelingTestBase.java | 4 +-
.../EventTimeWindowCheckpointingITCase.java | 4 +-
.../manual/StreamingScalabilityAndLatency.java | 4 +-
.../SuccessAfterNetworkBuffersFailureITCase.java | 4 +-
...tractTaskManagerProcessFailureRecoveryTest.java | 4 +-
.../JobManagerHAProcessFailureRecoveryITCase.java | 4 +-
.../recovery/ProcessFailureCancelingITCase.java | 4 +-
.../flink/test/runtime/NettyEpollITCase.java | 4 +-
.../yarn/YARNSessionCapacitySchedulerITCase.java | 4 +-
.../apache/flink/yarn/YarnConfigurationITCase.java | 6 +-
63 files changed, 1175 insertions(+), 869 deletions(-)
rename
flink-core/src/main/java/org/apache/flink/configuration/{NetworkEnvironmentOptions.java
=> NettyShuffleEnvironmentOptions.java} (99%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/{NetworkEnvironment.java
=> NettyShuffleEnvironment.java} (82%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleEnvironment.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleEnvironmentContext.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/{NetworkEnvironmentConfiguration.java
=> NettyShuffleEnvironmentConfiguration.java} (75%)
rename
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/{NetworkEnvironmentBuilder.java
=> NettyShuffleEnvironmentBuilder.java} (68%)
rename
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/{NetworkEnvironmentTest.java
=> NettyShuffleEnvironmentTest.java} (94%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/NettyShuffleEnvironmentConfigurationTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/NetworkEnvironmentConfigurationTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskManagerServicesConfigurationTest.java
