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 a0f747d [hotfix][runtime] Remove legacy NoOpIOManager class new a8b7222 [FLINK-12883][runtime] Extract computation of pipelined regions. new bce9a4c [hotfix][runtime] Use Set instead of IdentityHashMap where possible new efebb99 [hotfix][runtime] Remove obsolete comment from PipelinedRegionComputeUtil#uniqueRegions() new 2f5fc23 [FLINK-12883][runtime] Add getID() to ExecutionVertex new c9aa9a1 [FLINK-12883][runtime] Introduce PartitionReleaseStrategy The 5 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 | 9 + .../runtime/executiongraph/ExecutionGraph.java | 132 +++++++++++--- .../executiongraph/ExecutionGraphBuilder.java | 6 + .../runtime/executiongraph/ExecutionVertex.java | 9 + .../failover/flip1/PipelinedRegionComputeUtil.java | 131 +++++++++++++ .../flip1/RestartPipelinedRegionStrategy.java | 100 ++-------- .../NotReleasingPartitionReleaseStrategy.java | 56 ++++++ .../partitionrelease/PartitionReleaseStrategy.java | 58 ++++++ .../PartitionReleaseStrategyFactoryLoader.java} | 39 ++-- .../flip1/partitionrelease/PipelinedRegion.java | 69 +++++++ .../PipelinedRegionConsumedBlockingPartitions.java | 51 ++++++ .../PipelinedRegionExecutionView.java | 64 +++++++ .../RegionPartitionReleaseStrategy.java | 190 +++++++++++++++++++ .../ExecutionGraphPartitionReleaseTest.java | 202 +++++++++++++++++++++ .../RegionPartitionReleaseStrategyTest.java | 149 +++++++++++++++ .../PartitionReleaseStrategyFactoryLoaderTest.java | 55 ++++++ .../PipelinedRegionExecutionViewTest.java | 75 ++++++++ .../strategy/TestingSchedulingTopology.java | 14 +- 18 files changed, 1263 insertions(+), 146 deletions(-) create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/PipelinedRegionComputeUtil.java create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/NotReleasingPartitionReleaseStrategy.java create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/PartitionReleaseStrategy.java copy flink-runtime/src/{test/java/org/apache/flink/runtime/executiongraph/failover/flip1/TestRestartBackoffTimeStrategy.java => main/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/PartitionReleaseStrategyFactoryLoader.java} (51%) create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/PipelinedRegion.java create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/PipelinedRegionConsumedBlockingPartitions.java create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/PipelinedRegionExecutionView.java create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/RegionPartitionReleaseStrategy.java create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphPartitionReleaseTest.java create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/RegionPartitionReleaseStrategyTest.java create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/PartitionReleaseStrategyFactoryLoaderTest.java create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/PipelinedRegionExecutionViewTest.java