This is an automated email from the ASF dual-hosted git repository.
dmvk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 81902e81c43 [FLINK-32211][sql-client] Supports row format in executor
add 0c9403f8ad7 [FLINK-31892][runtime] Introduce AdaptiveScheduler global
failure enrichment/labeling
No new revisions were added by this update.
Summary of changes:
.../scheduler/adaptive/AdaptiveScheduler.java | 12 +++++-
.../flink/runtime/scheduler/adaptive/Created.java | 6 ++-
.../scheduler/adaptive/CreatingExecutionGraph.java | 4 +-
.../flink/runtime/scheduler/adaptive/Finished.java | 6 ++-
.../adaptive/LabeledGlobalFailureHandler.java | 43 ++++++++++++++++++++++
.../flink/runtime/scheduler/adaptive/State.java | 3 +-
.../adaptive/StateWithExecutionGraph.java | 5 ++-
.../scheduler/adaptive/StopWithSavepoint.java | 6 ++-
.../scheduler/adaptive/WaitingForResources.java | 5 ++-
.../exceptionhistory/ExceptionHistoryEntry.java | 6 +--
.../scheduler/adaptive/AdaptiveSchedulerTest.java | 28 +++++++++++++-
.../runtime/scheduler/adaptive/CancelingTest.java | 3 +-
.../runtime/scheduler/adaptive/CreatedTest.java | 4 +-
.../adaptive/CreatingExecutionGraphTest.java | 5 ++-
.../runtime/scheduler/adaptive/ExecutingTest.java | 11 ++++--
.../runtime/scheduler/adaptive/FailingTest.java | 3 +-
.../runtime/scheduler/adaptive/FinishedTest.java | 5 ++-
.../runtime/scheduler/adaptive/RestartingTest.java | 4 +-
.../adaptive/StateWithExecutionGraphTest.java | 3 +-
.../scheduler/adaptive/StopWithSavepointTest.java | 11 +++++-
.../adaptive/WaitingForResourcesTest.java | 5 ++-
21 files changed, 150 insertions(+), 28 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/LabeledGlobalFailureHandler.java
