[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
tree2852958c4891a89dab3e3a481d1b514edb0be80f
parent8a2a396970156f1ddecf88a6498162506eb25069
[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
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/BarrierAlignmentUtil.java [new file with mode: 0644]
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/CheckpointBarrierHandler.java
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/InputProcessorUtil.java
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/SingleCheckpointBarrierHandler.java
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/checkpointing/AlternatingCheckpointsTest.java
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/checkpointing/TestBarrierHandlerFactory.java