projects / flink.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: dd8f4e2) | patch
[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
tree903fe8c9c01a57584c8f8eca5efb961b57e8a7edtree | snapshot
parentdd8f4e2603309493300099396568ffc681e76e80commit | diff
[FLINK-27251][checkpoint] Refactor the close() and cancel() of SubtaskCheckpointCoordinator
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java diff | blob | history
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinator.java diff | blob | history
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java diff | blob | history
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/MockSubtaskCheckpointCoordinatorBuilder.java diff | blob | history
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorTest.java diff | blob | history
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TestSubtaskCheckpointCoordinator.java diff | blob | history
Apache Flink