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

Posted to commits@flink.apache.org by pn...@apache.org on 2022/02/07 16:23:56 UTC

[flink] branch master updated (1fac1c4 -> 271c593)

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

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


    from 1fac1c4  [FLINK-24780][table-planner] Port time/date/timestamp casts to new structure.
     add 271c593  [FLINK-24439][source] Introduce CoordinatorStore

No new revisions were added by this update.

Summary of changes:
 .../executiongraph/DefaultExecutionGraph.java      |  8 ++-
 .../runtime/executiongraph/ExecutionJobVertex.java |  6 ++-
 .../operators/coordination/CoordinatorStore.java}  | 40 ++++++++------
 .../coordination/CoordinatorStoreImpl.java         | 61 ++++++++++++++++++++++
 .../coordination/OperatorCoordinator.java          |  6 +++
 .../coordination/OperatorCoordinatorHolder.java    | 21 ++++++--
 .../RecreateOnResetOperatorCoordinator.java        |  5 ++
 .../source/coordinator/SourceCoordinator.java      |  7 ++-
 .../coordinator/SourceCoordinatorProvider.java     |  6 ++-
 .../executiongraph/ExecutionJobVertexTest.java     |  4 +-
 .../MockOperatorCoordinatorContext.java            |  6 +++
 .../OperatorCoordinatorHolderTest.java             |  1 +
 .../runtime/scheduler/adaptive/ExecutingTest.java  |  4 +-
 .../source/coordinator/SourceCoordinatorTest.java  | 10 ++--
 .../coordinator/SourceCoordinatorTestBase.java     |  7 ++-
 15 files changed, 162 insertions(+), 30 deletions(-)
 copy flink-runtime/src/{test/java/org/apache/flink/runtime/operators/coordination/MockOperatorEventGateway.java => main/java/org/apache/flink/runtime/operators/coordination/CoordinatorStore.java} (52%)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/CoordinatorStoreImpl.java