This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 32dd1b1 [FLINK-13427][hive] HiveCatalog's createFunction fails when
function name has upper-case characters
new ddaeffa [hotfix][tests] Remove setting the default value of
force-release-on-consumption
new b4d7bff [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make
release semantics fixed per partition type
new a7869bc [hotfix][network] fix codestyle issues in
ResultPartitionFactory
new 58e0ed2 [hotfix][network] Annotate
NettyShuffleDescriptor#PartitionConnectionInfo with @FunctionalInterface
new 18baca7 [hotfix][network] fix codestyle issues in NettyShuffleMaster
new 355a80a [hotfix] fix codestyle issues in ShuffleDescriptor
new 0b2161a [hotfix][tests] Make PartitionTestUtils enum singleton and
fix codestyle
new 9201cb8 [hotfix][tests] fix codestyle issues in ResultPartitionBuilder
new 06468ef [hotfix][tests] fix codestyle issues in
ResultPartitionFactoryTest
new 95d6d41 [hotfix][tests] fix codestyle issues in
NettyShuffleEnvironmentBuilder
new 0bbeedf [hotfix][tests] fix codestyle issues in
NettyShuffleDescriptorBuilder
new c422c71 [hotfix][tests] fix codestyle issues in
NettyShuffleEnvironmentConfiguration
new 18c3686 [hotfix][network] Simplify
ResultPartitionFactory.createSubpartitions based on
ResultPartitionType.isBlocking
new 039ec02 [hotfix][coordination] Check whether partition set to track
is empty
new b5ab84c [FLINK-13371][coordination] Prevent leaks of blocking
partitions
The 15 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 | 80 +++--
.../runtime/executiongraph/ExecutionGraph.java | 12 +-
.../executiongraph/ExecutionGraphBuilder.java | 4 -
.../runtime/executiongraph/ExecutionVertex.java | 4 +-
.../io/network/NettyShuffleServiceFactory.java | 3 +-
.../io/network/partition/PartitionTracker.java | 5 +
.../io/network/partition/PartitionTrackerImpl.java | 11 +-
.../network/partition/ResultPartitionFactory.java | 84 +++---
.../runtime/shuffle/NettyShuffleDescriptor.java | 20 +-
.../flink/runtime/shuffle/NettyShuffleMaster.java | 6 +-
.../flink/runtime/shuffle/ProducerDescriptor.java | 4 +-
.../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 +-
.../taskexecutor/partition/PartitionTable.java | 4 +
.../NettyShuffleEnvironmentConfiguration.java | 23 +-
.../ResultPartitionDeploymentDescriptorTest.java | 15 +-
.../ExecutionGraphDeploymentTest.java | 2 +-
.../ExecutionPartitionLifecycleTest.java | 324 +++++++++++++++++++++
.../runtime/executiongraph/ExecutionTest.java | 127 --------
.../io/network/NettyShuffleEnvironmentBuilder.java | 52 +---
.../io/network/partition/NoOpPartitionTracker.java | 4 +
.../io/network/partition/PartitionTestUtils.java | 67 +----
.../partition/PartitionTrackerImplTest.java | 46 ++-
.../network/partition/ResultPartitionBuilder.java | 9 +-
.../partition/ResultPartitionFactoryTest.java | 44 ++-
.../network/partition/TestingPartitionTracker.java | 10 +
.../TaskExecutorPartitionLifecycleTest.java | 52 +++-
.../taskexecutor/partition/PartitionTableTest.java | 9 +
.../util/NettyShuffleDescriptorBuilder.java | 17 +-
.../recovery/BatchFineGrainedRecoveryITCase.java | 2 +-
37 files changed, 646 insertions(+), 541 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionPartitionLifecycleTest.java
