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 d8b1a6f [FLINK-23372][streaming-java] Disable
AllVerticesInSameSlotSharingGroupByDefault in batch mode
add d200526 [FLINK-22017][coordination] Get the ConsumedPartitionGroup
that IntermediateResultPartition and DefaultResultPartition belong to
add eb8100f [FLINK-22017][coordination] Allow BLOCKING result partition
to be individually consumable
No new revisions were added by this update.
Summary of changes:
.../flink/runtime/executiongraph/EdgeManager.java | 22 ++++++
.../executiongraph/EdgeManagerBuildUtil.java | 67 ++++++++++++-----
.../flink/runtime/executiongraph/Execution.java | 14 +---
.../runtime/executiongraph/ExecutionVertex.java | 10 ++-
.../runtime/executiongraph/IntermediateResult.java | 22 ------
.../IntermediateResultPartition.java | 36 ++++-----
.../adapter/DefaultExecutionTopology.java | 3 +-
.../scheduler/adapter/DefaultResultPartition.java | 13 +++-
.../scheduler/strategy/ConsumedPartitionGroup.java | 23 ++++++
.../PipelinedRegionSchedulingStrategy.java | 40 ++--------
.../strategy/SchedulingResultPartition.java | 7 ++
.../DefaultExecutionGraphConstructionTest.java | 44 ++++++++++-
.../runtime/executiongraph/EdgeManagerTest.java | 87 ++++++++++++++++++++++
.../IntermediateResultPartitionTest.java | 79 +++++++++++++-------
...hedulingDownstreamTasksInBatchJobBenchmark.java | 23 ++----
.../PipelinedRegionSchedulingStrategyTest.java | 87 ++++++++++++----------
.../strategy/TestingSchedulingExecutionVertex.java | 11 ++-
.../strategy/TestingSchedulingResultPartition.java | 24 ++++++
.../strategy/TestingSchedulingTopology.java | 7 ++
19 files changed, 430 insertions(+), 189 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/EdgeManagerTest.java
