You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2021/03/30 09:18:34 UTC
[flink] branch master updated (626998d -> 9951be8)

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