This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 586d3d0 [FLINK-20347] Rework YARN resource provider page
add 52c4e97 [FLINK-20397][checkpointing] Pass checkpointId to
OperatorCoordinator.resetToCheckpoint()
add 0ea11b8 [FLINK-20396][checkpointing] Add a 'subtaskReset()' method to
the OperatorCoordinator.
No new revisions were added by this update.
Summary of changes:
.../runtime/checkpoint/CheckpointCoordinator.java | 16 +++-
.../OperatorCoordinatorCheckpointContext.java | 13 ++-
.../coordination/OperatorCoordinator.java | 35 +++++--
.../coordination/OperatorCoordinatorHolder.java | 10 +-
.../RecreateOnResetOperatorCoordinator.java | 21 ++++-
.../flink/runtime/scheduler/SchedulerBase.java | 81 +++++++++++++++-
.../source/coordinator/SourceCoordinator.java | 10 +-
.../CheckpointCoordinatorTestingUtils.java | 5 +-
.../checkpoint/CheckpointIDCounterTestBase.java | 21 +++++
.../CoordinatorEventsExactlyOnceITCase.java | 7 +-
.../coordination/MockOperatorCoordinator.java | 7 +-
.../OperatorCoordinatorHolderTest.java | 11 ++-
.../OperatorCoordinatorSchedulerTest.java | 102 ++++++++++++++++++++-
.../RecreateOnResetOperatorCoordinatorTest.java | 8 +-
.../coordination/TestingOperatorCoordinator.java | 31 ++++++-
.../coordinator/SourceCoordinatorProviderTest.java | 2 +-
.../source/coordinator/SourceCoordinatorTest.java | 6 +-
.../collect/CollectSinkOperatorCoordinator.java | 7 +-
18 files changed, 350 insertions(+), 43 deletions(-)
