You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ch...@apache.org on 2022/02/16 08:54:16 UTC

[flink] branch master updated (540d876 -> b64a838)

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%)