This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from fdeb8484df6 [FLINK-38993][table] Move materialized table query change
validation logic from converter to operation
add 2ac5d28d5dc [FLINK-33123][runtime] Fix the wrong dynamic replacement
of partitioner from FORWARD to REBALANCE for autoscaler and adaptive scheduler
No new revisions were added by this update.
Summary of changes:
.../runtime/jobgraph/IntermediateDataSet.java | 6 +
.../org/apache/flink/runtime/jobgraph/JobEdge.java | 18 ++-
.../scheduler/adaptive/AdaptiveScheduler.java | 6 +-
.../scheduler/adaptive/ForwardEdgesAdapter.java | 75 ++++++++++
.../adaptive/ForwardEdgesAdapterTest.java | 160 +++++++++++++++++++++
5 files changed, 262 insertions(+), 3 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/ForwardEdgesAdapter.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/ForwardEdgesAdapterTest.java
