This is an automated email from the ASF dual-hosted git repository.
lindong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 9ed70a1e8b5 [FLINK-28178][runtime-web] Show the delegated StateBackend
and whether changelog is enabled in the UI
add 1486743ef3d [FLINK-28606][Runtime/Checkpointing] Preserve consistency
of OperatorEvent from OperatorCoordinator to subtasks
add 7be6783cb22 [FLINK-28606][Runtime/Checkpointing] Refractor
coordination tests with JUnit5 Assertions
No new revisions were added by this update.
Summary of changes:
.../runtime/checkpoint/CheckpointCoordinator.java | 2 -
.../OperatorCoordinatorCheckpointContext.java | 2 -
.../checkpoint/OperatorCoordinatorCheckpoints.java | 2 +-
...andler.java => AcknowledgeCheckpointEvent.java} | 20 +-
.../operators/coordination/EventSender.java | 37 --
.../coordination/OperatorCoordinatorHolder.java | 139 ++++--
.../operators/coordination/OperatorEventValve.java | 202 --------
.../operators/coordination/SubtaskAccess.java | 6 +-
.../operators/coordination/SubtaskGatewayImpl.java | 177 ++++++-
.../CheckpointCoordinatorTestingUtils.java | 24 +-
.../coordination/ComponentClosingUtilsTest.java | 64 +--
.../CoordinatorEventsExactlyOnceITCase.java | 160 +++---
.../coordination/EventReceivingTasks.java | 56 ++-
.../OperatorCoordinatorHolderTest.java | 125 +++--
.../OperatorCoordinatorSchedulerTest.java | 221 ++++----
.../coordination/OperatorEventValveTest.java | 133 -----
.../RecreateOnResetOperatorCoordinatorTest.java | 82 +--
.../coordination/SubtaskGatewayImplTest.java | 175 +++++++
.../coordination/TestingOperatorCoordinator.java | 7 +
.../util/IncompleteFuturesTrackerTest.java | 29 +-
.../runtime/tasks/FinishedOperatorChain.java | 1 +
.../streaming/runtime/tasks/OperatorChain.java | 16 +
.../runtime/tasks/OperatorEventDispatcherImpl.java | 5 +
.../runtime/tasks/RegularOperatorChain.java | 1 +
...ToStreamOperatorRecipientExactlyOnceITCase.java | 553 +++++++++++++++++++++
.../tasks/SubtaskCheckpointCoordinatorTest.java | 1 +
26 files changed, 1432 insertions(+), 808 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/{OperatorEventHandler.java
=> AcknowledgeCheckpointEvent.java} (63%)
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/EventSender.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorEventValve.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/OperatorEventValveTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/SubtaskGatewayImplTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.java
