You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2021/02/10 14:30:40 UTC
[flink] branch master updated (4fd2cec -> 177310e)

This is an automated email from the ASF dual-hosted git repository.

rmetzger pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 4fd2cec  [FLINK-19520][configuration] Add randomization of checkpoint config in ITCases.
     add 021d4f6  [hotfix] Move SchedulerBase specific queryable state logic into KvStateHandler to make it reusable
     add f00ed29  [hotfix] Introduce ExecutionGraphHandler to factor out ExecutionGraph logic from the SchedulerBase
     add 9a4d129  [hotfix] Do not pass SchedulerNG to OperatorCoordinatorHolder
     add d509277  [hotfix] Introduce OperatorCoordinatorHandler for factoring out logic from the SchedulerBase
     add 28585ac  [FLINK-21256] Add Executing state for declarative scheduler
     add d0bcad6  [FLINK-21256] Add tests for Executing state
     add cd6abf6  [FLINK-21257] Add Restarting state for declarative scheduler
     add 177310e  [FLINK-21257] Add RestartingTest

No new revisions were added by this update.

Summary of changes:
 .../runtime/executiongraph/ExecutionJobVertex.java |   4 +-
 .../runtime/executiongraph/ExecutionVertex.java    |   3 +-
 .../coordination/OperatorCoordinatorHolder.java    |   7 -
 .../runtime/scheduler/ExecutionGraphHandler.java   | 225 ++++++++
 .../flink/runtime/scheduler/KvStateHandler.java    | 135 +++++
 .../scheduler/OperatorCoordinatorHandler.java      | 147 +++++
 .../flink/runtime/scheduler/SchedulerBase.java     | 317 ++---------
 .../runtime/scheduler/declarative/Executing.java   | 260 +++++++++
 .../runtime/scheduler/declarative/Restarting.java  | 114 ++++
 .../flink/runtime/scheduler/declarative/State.java |   7 +
 .../declarative/StateWithExecutionGraph.java       | 349 ++++++++++++
 ...nuallyTriggeredComponentMainThreadExecutor.java |  41 ++
 .../ExecutionVertexDeploymentTest.java             |   2 +-
 .../scheduler/declarative/ExecutingTest.java       | 611 +++++++++++++++++++++
 .../MockStateWithExecutionGraphContext.java        |  80 +++
 .../scheduler/declarative/RestartingTest.java      | 223 ++++++++
 .../scheduler/declarative/StateValidator.java      |   7 +-
 17 files changed, 2242 insertions(+), 290 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionGraphHandler.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/KvStateHandler.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/OperatorCoordinatorHandler.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/declarative/Executing.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/declarative/Restarting.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/declarative/StateWithExecutionGraph.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ManuallyTriggeredComponentMainThreadExecutor.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/declarative/ExecutingTest.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/declarative/MockStateWithExecutionGraphContext.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/declarative/RestartingTest.java