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 34924affa9c [FLINK-36227] Restore compatibility with Logback 1.2
new 81a1de166d1 [hotfix][runtime]
ConsumedSubpartitionContext#getConsumedShuffleDescriptorRanges should return a
non-overlapping result
new 082cfe82a0f [FLINK-36576][runtime] Introduce two correlations to allow
operators to flexibly choose the data distribution algorithm
new 4860f38f894 [FLINK-36576][runtime] Introduce BlockingInputInfo to
provide more input information for parallelism decider
new 7f1c201d92b [FLINK-36576][runtime] Improving amount-based data
balancing distribution algorithm for
DefaultVertexParallelismAndInputInfosDecider
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../deployment/ConsumedSubpartitionContext.java | 11 +-
.../VertexInputInfoComputationUtils.java | 2 +-
.../org/apache/flink/runtime/jobgraph/JobEdge.java | 39 +-
.../apache/flink/runtime/jobgraph/JobVertex.java | 35 +-
.../adaptivebatch/AbstractBlockingResultInfo.java | 27 +
.../adaptivebatch/AdaptiveBatchScheduler.java | 59 +-
.../AdaptiveBatchSchedulerFactory.java | 11 +
.../adaptivebatch/AllToAllBlockingResultInfo.java | 26 -
.../BatchExecutionOptionsInternal.java | 49 ++
.../adaptivebatch/BisectionSearchUtils.java | 2 +-
.../scheduler/adaptivebatch/BlockingInputInfo.java | 139 +++++
...faultVertexParallelismAndInputInfosDecider.java | 506 ++++------------
.../adaptivebatch/PointwiseBlockingResultInfo.java | 27 -
.../VertexParallelismAndInputInfosDecider.java | 2 +-
.../util/AggregatedBlockingInputInfo.java | 189 ++++++
.../util/AllToAllVertexInputInfoComputer.java | 486 +++++++++++++++
.../util/PointwiseVertexInputInfoComputer.java | 185 ++++++
.../adaptivebatch/util/SubpartitionSlice.java | 135 +++++
...VertexParallelismAndInputInfosDeciderUtils.java | 661 +++++++++++++++++++++
.../flink/streaming/api/graph/StreamEdge.java | 48 ++
.../api/graph/StreamingJobGraphGenerator.java | 10 +-
.../ConsumedSubpartitionContextTest.java | 4 +-
.../IntermediateResultPartitionTest.java | 10 +-
.../runtime/scheduler/DefaultSchedulerBuilder.java | 4 +-
...tVertexParallelismAndInputInfosDeciderTest.java | 136 ++---
.../VertexInputInfoComputerTestUtil.java | 342 +++++++++++
.../util/AggregatedBlockingInputInfoTest.java | 102 ++++
.../util/AllToAllVertexInputInfoComputerTest.java | 400 +++++++++++++
.../util/PointwiseVertexInputInfoComputerTest.java | 172 ++++++
.../adaptivebatch/util/SubpartitionSliceTest.java | 102 ++++
...exParallelismAndInputInfosDeciderUtilsTest.java | 214 +++++++
31 files changed, 3597 insertions(+), 538 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/BatchExecutionOptionsInternal.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/BlockingInputInfo.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/util/AggregatedBlockingInputInfo.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/util/AllToAllVertexInputInfoComputer.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/util/PointwiseVertexInputInfoComputer.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/util/SubpartitionSlice.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/util/VertexParallelismAndInputInfosDeciderUtils.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/VertexInputInfoComputerTestUtil.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/util/AggregatedBlockingInputInfoTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/util/AllToAllVertexInputInfoComputerTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/util/PointwiseVertexInputInfoComputerTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/util/SubpartitionSliceTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/util/VertexParallelismAndInputInfosDeciderUtilsTest.java
