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/10 14:22:22 UTC

[flink] branch master updated (c0ce550 -> 5180e83)

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 c0ce550  [FLINK-26035][build][planner] Add table-planner-loader-bundle module
     add 5180e83  [FLINK-25755][runtime] Introduce shared state transition interfaces

No new revisions were added by this update.

Summary of changes:
 .../scheduler/adaptive/AdaptiveScheduler.java      |  35 ++---
 .../flink/runtime/scheduler/adaptive/Created.java  |  13 +-
 .../scheduler/adaptive/CreatingExecutionGraph.java |  73 ++++++----
 .../runtime/scheduler/adaptive/Executing.java      |  70 +--------
 .../flink/runtime/scheduler/adaptive/Failing.java  |  16 +--
 .../runtime/scheduler/adaptive/Restarting.java     |  22 +--
 .../scheduler/adaptive/StateTransitions.java       | 157 +++++++++++++++++++++
 .../adaptive/StateWithExecutionGraph.java          |  10 +-
 .../scheduler/adaptive/StopWithSavepoint.java      |  66 +--------
 .../scheduler/adaptive/WaitingForResources.java    |  13 +-
 .../adaptive/CreatingExecutionGraphTest.java       |  21 ++-
 11 files changed, 254 insertions(+), 242 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateTransitions.java