This is an automated email from the ASF dual-hosted git repository.
zhijiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from cf763d5 [FLINK-13491][datastream] correctly support endInput in
AsyncWaitOperator
new 642965c [hotfix][tests] Remove setting the default value of
force-release-on-consumption
new 6ce4e2b [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make
release semantics fixed per partition type
new ac0e204 [hotfix][network] fix codestyle issues in
ResultPartitionFactory
new 7ee937c [hotfix][network] Annotate
NettyShuffleDescriptor#PartitionConnectionInfo with @FunctionalInterface
new f810a1a [hotfix][network] fix codestyle issues in NettyShuffleMaster
new 45f77bb5 [hotfix] fix codestyle issues in ShuffleDescriptor
new e408636 [hotfix][tests] Make PartitionTestUtils enum singleton and
fix codestyle
new e0617be [hotfix][tests] fix codestyle issues in ResultPartitionBuilder
new e593c5d7 [hotfix][tests] fix codestyle issues in
ResultPartitionFactoryTest
new 4437249 [hotfix][tests] fix codestyle issues in
NettyShuffleEnvironmentBuilder
new 8735a5b [hotfix][tests] fix codestyle issues in
NettyShuffleDescriptorBuilder
new 7ec0768 [hotfix][tests] fix codestyle issues in
NettyShuffleEnvironmentConfiguration
new 7fe12c9 [hotfix][network] Simplify
ResultPartitionFactory.createSubpartitions based on
ResultPartitionType.isBlocking
The 13 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/configuration/JobManagerOptions.java | 5 --
.../NettyShuffleEnvironmentOptions.java | 5 ++
.../test-scripts/test_ha_dataset.sh | 1 -
.../ResultPartitionDeploymentDescriptor.java | 57 ---------------
.../flink/runtime/executiongraph/Execution.java | 9 +--
.../runtime/executiongraph/ExecutionGraph.java | 10 ---
.../executiongraph/ExecutionGraphBuilder.java | 4 --
.../io/network/NettyShuffleServiceFactory.java | 3 +-
.../io/network/partition/PartitionTrackerImpl.java | 4 +-
.../network/partition/ResultPartitionFactory.java | 84 ++++++++++------------
.../runtime/shuffle/NettyShuffleDescriptor.java | 20 +-----
.../flink/runtime/shuffle/NettyShuffleMaster.java | 6 +-
.../flink/runtime/shuffle/ShuffleDescriptor.java | 38 ++--------
.../flink/runtime/shuffle/ShuffleEnvironment.java | 26 ++++---
.../flink/runtime/shuffle/ShuffleMaster.java | 5 --
.../runtime/shuffle/UnknownShuffleDescriptor.java | 6 --
.../flink/runtime/taskexecutor/TaskExecutor.java | 4 +-
.../NettyShuffleEnvironmentConfiguration.java | 23 ++++--
.../ResultPartitionDeploymentDescriptorTest.java | 15 +---
.../io/network/NettyShuffleEnvironmentBuilder.java | 52 ++++----------
.../io/network/partition/PartitionTestUtils.java | 67 ++++-------------
.../partition/PartitionTrackerImplTest.java | 43 ++++++-----
.../network/partition/ResultPartitionBuilder.java | 9 +--
.../partition/ResultPartitionFactoryTest.java | 44 +++++++++---
.../TaskExecutorPartitionLifecycleTest.java | 3 +-
.../util/NettyShuffleDescriptorBuilder.java | 17 ++---
.../recovery/BatchFineGrainedRecoveryITCase.java | 2 +-
27 files changed, 181 insertions(+), 381 deletions(-)
