This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 626998d [FLINK-21630][python] Support Python UDAF in Session Window
add e9f1d2d [hotfix] Rename ExecutionVertex#getConsumedPartitions to
ExecutionVertex#getConsumedPartitionGroup
add 30f435c [hotfix] Rename IntermediateResultPartition#getConsumers to
IntermediateResultPartition#getConsumerVertexGroups
add 9951be8 [FLINK-21332] Optimize releasing result partitions in
RegionPartitionReleaseStrategy
No new revisions were added by this update.
Summary of changes:
.../DefaultCheckpointPlanCalculator.java | 2 +-
.../TaskDeploymentDescriptorFactory.java | 2 +-
.../flink/runtime/executiongraph/Execution.java | 14 +--
.../runtime/executiongraph/ExecutionVertex.java | 2 +-
.../IntermediateResultPartition.java | 2 +-
.../ConsumerRegionGroupExecutionView.java | 60 +++++++++++
...ConsumerRegionGroupExecutionViewMaintainer.java | 71 +++++++++++++
.../RegionPartitionReleaseStrategy.java | 76 +++++++++-----
.../flink/runtime/shuffle/PartitionDescriptor.java | 8 +-
.../executiongraph/ExecutionGraphTestUtils.java | 8 +-
.../executiongraph/PointwisePatternTest.java | 32 +++---
...umerRegionGroupExecutionViewMaintainerTest.java | 114 +++++++++++++++++++++
.../adapter/DefaultExecutionTopologyTest.java | 3 +-
.../partitioner/RescalePartitionerTest.java | 8 +-
14 files changed, 338 insertions(+), 64 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/ConsumerRegionGroupExecutionView.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/ConsumerRegionGroupExecutionViewMaintainer.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/ConsumerRegionGroupExecutionViewMaintainerTest.java
