This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e2dd0b6 [FLINK-19671][codestyle] Revert .editorconfig change
violating our coding style
add efe588e [hotfix][network] Remove unused EventSerializer#isEvent method
add e24c8b6 [hotfix][network] Rename
ALIGNED_EXACTLY_ONCE_CHECKPOINT_BARRIER and improve java docs in DataType
add 63110a1 [hotfix][checkpointing] Remove unused variable in
AlternatingController
add fda1679 [FLINK-19680][checkpointing] Provide alignment timeout
checkpoint option
add eb24d38 [FLINK-19680][checkpointing] Announce timeoutable
CheckpointBarriers
No new revisions were added by this update.
Summary of changes:
.../execution_checkpointing_configuration.html | 6 ++
.../flink/state/api/output/SnapshotUtils.java | 3 +-
.../runtime/checkpoint/CheckpointCoordinator.java | 8 +-
.../runtime/checkpoint/CheckpointOptions.java | 56 ++++++++++---
...eckpointBarrier.java => EventAnnouncement.java} | 62 +++++---------
.../network/api/serialization/EventSerializer.java | 84 +++++++------------
.../flink/runtime/io/network/buffer/Buffer.java | 75 +++++++++++++----
.../partition/consumer/RemoteInputChannel.java | 49 ++++++++---
.../tasks/CheckpointCoordinatorConfiguration.java | 22 ++++-
.../runtime/checkpoint/CheckpointOptionsTest.java | 59 +++++++++++--
.../api/serialization/EventSerializerTest.java | 97 ++++------------------
.../network/netty/PartitionRequestQueueTest.java | 2 +-
.../PipelinedSubpartitionWithReadViewTest.java | 8 +-
.../partition/consumer/LocalInputChannelTest.java | 2 +-
.../partition/consumer/RemoteInputChannelTest.java | 44 ++++++++++
.../api/environment/CheckpointConfig.java | 28 +++++++
.../environment/ExecutionCheckpointingOptions.java | 16 ++++
.../flink/streaming/api/graph/StreamConfig.java | 10 +++
.../api/graph/StreamingJobGraphGenerator.java | 2 +
.../runtime/io/AlternatingController.java | 3 +-
.../runtime/io/CheckpointBarrierHandler.java | 5 ++
.../runtime/io/CheckpointBarrierTracker.java | 8 ++
.../runtime/io/CheckpointedInputGate.java | 19 ++++-
.../runtime/io/SingleCheckpointBarrierHandler.java | 8 ++
.../streaming/runtime/tasks/SourceStreamTask.java | 4 +-
.../runtime/io/AlternatingControllerTest.java | 40 ++++++++-
.../runtime/io/InputProcessorUtilTest.java | 2 +-
...tStreamTaskChainedSourcesCheckpointingTest.java | 55 ++++++++----
.../runtime/tasks/MultipleInputStreamTaskTest.java | 1 +
.../tasks/SubtaskCheckpointCoordinatorTest.java | 2 +-
.../checkpointing/UnalignedCheckpointITCase.java | 1 +
31 files changed, 516 insertions(+), 265 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/{CheckpointBarrier.java
=> EventAnnouncement.java} (52%)
