This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 4ba336656b6 [FLINK-30402][security][runtime] Separate token framework
generic and hadoop specific parts
new 40a44e0ee6b [hotfix] Migrate VertexwiseSchedulingStrategyTest to
JUnit5 and AssertJ.
new e739b3853a6 [FLINK-29767] Introduce InputConsumableDecider and using
it to decide are input all consumable for VertexwiseSchedulingStrategy.
new 022f7adeb86 [FLINK-29767] Let consumerVertexGroup also know the type
of result partition.
new a6a321777a5 [FLINK-29767] VertexwiseSchedulingStrategy supports hybrid
shuffle edge.
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:
.../executiongraph/EdgeManagerBuildUtil.java | 12 +-
.../scheduler/strategy/ConsumerVertexGroup.java | 22 ++-
.../strategy/DefaultInputConsumableDecider.java | 107 ++++++++++++
.../scheduler/strategy/InputConsumableDecider.java | 50 ++++++
.../strategy/VertexwiseSchedulingStrategy.java | 124 +++++++++-----
.../adapter/DefaultResultPartitionTest.java | 4 +-
.../DefaultInputConsumableDeciderTest.java | 189 +++++++++++++++++++++
.../strategy/TestingInputConsumableDecider.java | 56 ++++++
.../strategy/TestingSchedulingResultPartition.java | 7 +-
.../strategy/TestingSchedulingTopology.java | 8 +-
.../strategy/VertexwiseSchedulingStrategyTest.java | 153 +++++++++++------
11 files changed, 621 insertions(+), 111 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/DefaultInputConsumableDecider.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/InputConsumableDecider.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/DefaultInputConsumableDeciderTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/TestingInputConsumableDecider.java
