This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 540d876 [FLINK-26017][runtime] Adds log message to when a job is
marked as dirty
add b64a838 [FLINK-26107][runtime] OperatorCoordinator uses failure
handler of the current state
No new revisions were added by this update.
Summary of changes:
.../coordination/OperatorCoordinatorHolder.java | 17 +--
.../DefaultOperatorCoordinatorHandler.java | 7 +-
...catorFactory.java => GlobalFailureHandler.java} | 15 ++-
.../flink/runtime/scheduler/SchedulerNG.java | 4 +-
.../scheduler/adaptive/CreatingExecutionGraph.java | 37 +++++-
.../flink/runtime/scheduler/adaptive/State.java | 10 +-
.../OperatorCoordinatorHolderTest.java | 4 +-
.../adaptive/CreatingExecutionGraphTest.java | 132 +++++++++++++++++----
.../TestingOperatorCoordinatorHandler.java | 4 +-
9 files changed, 166 insertions(+), 64 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/{ExecutionSlotAllocatorFactory.java
=> GlobalFailureHandler.java} (65%)
