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/12/30 10:59:16 UTC
[flink] branch master updated (4b05b00 -> 35d3d31)

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 4b05b00  [FLINK-25398] Show complete stacktrace when requesting thread dump
     add 1525556  [FLINK-18295][runtime] Change result partition to explicitly have one ConsumerVertexGroup (instead of a collection of ConsumerVertexGroup)
     add 35d3d31  [FLINK-18295][runtime] Change IntermediateDataSet to explicitly have exactly one consumer vertex

No new revisions were added by this update.

Summary of changes:
 .../TaskDeploymentDescriptorFactory.java           |   2 +-
 .../flink/runtime/executiongraph/EdgeManager.java  |  21 +----
 .../flink/runtime/executiongraph/Execution.java    |  23 +----
 .../IntermediateResultPartition.java               |   6 +-
 .../RestartPipelinedRegionFailoverStrategy.java    |  11 +--
 .../SchedulingPipelinedRegionComputeUtil.java      |  27 +++---
 .../runtime/jobgraph/IntermediateDataSet.java      |  16 ++--
 .../apache/flink/runtime/jobgraph/JobGraph.java    |   5 +-
 .../apache/flink/runtime/jobgraph/JobVertex.java   |  11 +--
 .../jobgraph/topology/DefaultLogicalResult.java    |  12 ---
 .../SsgNetworkMemoryCalculationUtils.java          |   8 +-
 .../adapter/DefaultExecutionTopology.java          |  11 +--
 .../scheduler/adapter/DefaultResultPartition.java  |  23 +----
 .../adapter/DefaultSchedulingPipelinedRegion.java  |   5 -
 .../strategy/SchedulingResultPartition.java        |   6 +-
 .../flink/runtime/shuffle/PartitionDescriptor.java |  22 ++---
 .../org/apache/flink/runtime/topology/Result.java  |   2 -
 .../DefaultExecutionGraphConstructionTest.java     | 101 ---------------------
 .../executiongraph/EdgeManagerBuildUtilTest.java   |   4 +-
 .../flink/runtime/jobgraph/JobTaskVertexTest.java  |  27 +-----
 .../topology/DefaultLogicalResultTest.java         |  24 ++---
 .../topology/DefaultLogicalVertexTest.java         |  53 +++++------
 .../adapter/DefaultExecutionTopologyTest.java      |  18 +---
 .../strategy/TestingSchedulingResultPartition.java |  42 ++++-----
 .../strategy/TestingSchedulingTopology.java        |  19 +---
 .../validation/TestJobDataFlowValidator.java       |  34 ++++---
 26 files changed, 144 insertions(+), 389 deletions(-)