projects / flink.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 8a2a396) | patch
[FLINK-27251][checkpoint] Refactor the barrier alignment timer and default priority...
authorfanrui <1996fanrui@gmail.com>
Fri, 20 May 2022 09:36:16 +0000 (17:36 +0800)
committerPiotr Nowojski <pnowojski@users.noreply.github.com>
Wed, 25 May 2022 06:32:07 +0000 (08:32 +0200)
commit10b7afae7423d75f94f397699b09deb9fbbdaca5
tree2852958c4891a89dab3e3a481d1b514edb0be80ftree | snapshot
parent8a2a396970156f1ddecf88a6498162506eb25069commit | diff
[FLINK-27251][checkpoint] Refactor the barrier alignment timer and default priority sequence number
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java diff | blob | history
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/BarrierAlignmentUtil.java [new file with mode: 0644] blob
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/CheckpointBarrierHandler.java diff | blob | history
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/InputProcessorUtil.java diff | blob | history
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/SingleCheckpointBarrierHandler.java diff | blob | history
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/checkpointing/AlternatingCheckpointsTest.java diff | blob | history
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/checkpointing/TestBarrierHandlerFactory.java diff | blob | history
Apache Flink