[FLINK-27251][checkpoint] Timeout aligned to unaligned checkpoint barrier in the...
authorfanrui <1996fanrui@gmail.com>
Sat, 14 May 2022 14:50:39 +0000 (22:50 +0800)
committerPiotr Nowojski <pnowojski@users.noreply.github.com>
Wed, 25 May 2022 06:32:07 +0000 (08:32 +0200)
commitdd8f4e2603309493300099396568ffc681e76e80
tree8062dd0981ba69cb8d1c0a3c3ce587d93baebdea
parent10b7afae7423d75f94f397699b09deb9fbbdaca5
[FLINK-27251][checkpoint] Timeout aligned to unaligned checkpoint barrier in the output buffers
25 files changed:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointOptions.java
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriter.java
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/ResultPartitionWriter.java
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartition.java
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestDispatcherTest.java
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/MockChannelStateWriter.java
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/InputChannelTestUtils.java
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/MockResultPartitionWriter.java
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionTest.java
flink-runtime/src/test/java/org/apache/flink/runtime/state/ChannelPersistenceITCase.java
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordWriterOutput.java
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/AbstractAlternatingAlignedBarrierHandlerState.java
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/AlternatingCollectingBarriers.java
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
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/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