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 2022/01/20 04:34:55 UTC
[flink] branch master updated (23c1637 -> 355b165)

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 23c1637  [FLINK-22643][network] Reuse tpc connections between taskmanagers
     add 2357325  [hotfix][runtime] Add checkNotNull for Supplier/Function in DefaultResultPartition/DefaultExecutionVertex.
     add 82b0703  [FLINK-25033][runtime] DefaultExecutionTopology supports update.
     add 355b165  [FLINK-25033][runtime] RegionPartitionGroupReleaseStrategy and LocalInputPreferredSlotSharingStrategy support update.

No new revisions were added by this update.

Summary of changes:
 .../RestartPipelinedRegionFailoverStrategy.java    |   9 +-
 .../SchedulingPipelinedRegionComputeUtil.java      |   9 +-
 ...ConsumerRegionGroupExecutionViewMaintainer.java |   3 +-
 .../RegionPartitionGroupReleaseStrategy.java       |  72 ++++--
 .../LocalInputPreferredSlotSharingStrategy.java    |  35 ++-
 ...riever.java => SchedulingTopologyListener.java} |  19 +-
 .../adapter/DefaultExecutionTopology.java          | 278 +++++++++++----------
 .../scheduler/adapter/DefaultExecutionVertex.java  |  13 +-
 .../scheduler/adapter/DefaultResultPartition.java  |  29 +--
 .../strategy/SchedulingResultPartition.java        |   5 +-
 .../scheduler/strategy/SchedulingTopology.java     |  12 +
 .../RegionPartitionGroupReleaseStrategyTest.java   |  28 +++
 ...umerRegionGroupExecutionViewMaintainerTest.java |   5 +-
 ...LocalInputPreferredSlotSharingStrategyTest.java |  52 ++++
 .../adapter/DefaultExecutionTopologyTest.java      |  92 ++++++-
 .../adapter/DefaultExecutionVertexTest.java        |  14 +-
 .../adapter/DefaultResultPartitionTest.java        |  34 ++-
 .../DefaultSchedulingPipelinedRegionTest.java      |   6 +-
 .../strategy/TestingSchedulingResultPartition.java |   6 +-
 .../strategy/TestingSchedulingTopology.java        |   4 +
 20 files changed, 518 insertions(+), 207 deletions(-)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/{StateLocationRetriever.java => SchedulingTopologyListener.java} (62%)