[FLINK-27251][checkpoint] Refactor the close() and cancel() of SubtaskCheckpointCoord...
authorfanrui <1996fanrui@gmail.com>
Tue, 24 May 2022 10:06:58 +0000 (18:06 +0800)
committerPiotr Nowojski <pnowojski@users.noreply.github.com>
Wed, 25 May 2022 06:32:07 +0000 (08:32 +0200)
commite68d679e8aca9b8b17e1b667188545c915a137d0
tree903fe8c9c01a57584c8f8eca5efb961b57e8a7ed
parentdd8f4e2603309493300099396568ffc681e76e80
[FLINK-27251][checkpoint] Refactor the close() and cancel() of SubtaskCheckpointCoordinator
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinator.java
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/MockSubtaskCheckpointCoordinatorBuilder.java
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TestSubtaskCheckpointCoordinator.java