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 3c0442e [hotfix] Fix incorrect output type in
StreamExecTableSourceScan & BatchExecTableSourceScan
new f4ba4df [hotfix][test] Improve error message in
ValidatingCheckpointHandler
new 37e0fb4 [hotfix][test] Fix StreamConfig propagation to StreamTask in
StreamTaskMailboxTestHarnessBuilder
new 5d446d2 [FLINK-19681][checkpointing] Choose controler before
processing first barrier or announcement
new c5c46ab [FLINK-19681][checkpointing] Timeout aligned checkpoints
based on checkpointStartDelay
new c0b9089 [FLINK-19681][tests] Adjust alignmentTimeout in unaligned
checkpoint ITCases
new 28a8014 [FLINK-19681][config][checkpointing] Un-hide alignment
timeout option
new 6710045 [hotfix][network] Report channel index if failied to
deserialize
new f11452e [hotfix][checkpointing] Add preconditions to channels and
controllers
new b49ad67 [FLINK-19681][checkpointing] Fix barrier tracking in input
channels
new f40b4eb [FLINK-19681][checkpointing] Reset channel barrier tracking
from AlignedController
new 033b4f3 [FLINK-19681][checkpointing] Resume consumption when
receiving different upstream signals
new 002a584 [FLINK-19681][checkpointing] Use converted barrier after
disabling alignment
new cf3b861 [FLINK-19681][checkpointing] Address minor feedback
new b16a62a [FLINK-19681][checkpointing] Use time of start of alignment
instead of checkpoint to timeout
new 9fdbbfc [FLINK-19681][checkpointing] Switch controller before
processing the first barrier
new d5043c9 [FLINK-19681][checkpointing] Don't timeout checkpoint on last
barrier
new 26ca3f6 [hotfix][checkpointing] Explicit creation of CheckpointOptions
new cd6967c [FLINK-19681][network] Force priority for converted barriers
The 18 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../execution_checkpointing_configuration.html | 6 +
.../runtime/checkpoint/CheckpointCoordinator.java | 2 +-
.../runtime/checkpoint/CheckpointOptions.java | 80 +++-
.../runtime/io/network/api/CheckpointBarrier.java | 4 +
.../partition/BufferWritingResultPartition.java | 3 +
.../io/network/partition/PrioritizedDeque.java | 22 +
.../partition/consumer/ChannelStatePersister.java | 35 +-
.../partition/consumer/CheckpointableInput.java | 2 +
.../partition/consumer/IndexedInputGate.java | 7 +
.../network/partition/consumer/InputChannel.java | 3 +
.../partition/consumer/LocalInputChannel.java | 7 +-
.../partition/consumer/RemoteInputChannel.java | 78 +++-
.../partition/consumer/SingleInputGate.java | 16 +-
.../checkpoint/CheckpointCoordinatorTest.java | 5 +-
.../runtime/checkpoint/CheckpointOptionsTest.java | 53 +--
.../api/serialization/EventSerializerTest.java | 8 +-
.../PipelinedSubpartitionWithReadViewTest.java | 15 +-
.../io/network/partition/PrioritizedDequeTest.java | 27 ++
.../partition/consumer/LocalInputChannelTest.java | 41 +-
.../partition/consumer/RemoteInputChannelTest.java | 91 ++++-
.../environment/ExecutionCheckpointingOptions.java | 1 -
.../streaming/runtime/io/AlignedController.java | 70 +++-
.../runtime/io/AlternatingController.java | 113 +++++-
.../io/CheckpointBarrierBehaviourController.java | 17 +-
.../runtime/io/SingleCheckpointBarrierHandler.java | 116 ++++--
.../runtime/io/StreamTaskNetworkInput.java | 7 +-
.../runtime/io/StreamTaskSourceInput.java | 5 +
.../streaming/runtime/io/UnalignedController.java | 30 +-
.../runtime/tasks/SourceOperatorStreamTask.java | 6 +-
.../streaming/runtime/tasks/SourceStreamTask.java | 6 +-
.../runtime/tasks/mailbox/MailboxProcessor.java | 5 +
.../io/AlignedControllerMassiveRandomTest.java | 6 +-
.../runtime/io/AlignedControllerTest.java | 35 +-
.../runtime/io/AlternatingControllerTest.java | 445 +++++++++++++++++----
.../runtime/io/InputProcessorUtilTest.java | 3 +-
.../runtime/io/StreamTaskNetworkInputTest.java | 2 +-
.../io/UnalignedControllerCancellationTest.java | 2 +-
.../runtime/io/UnalignedControllerTest.java | 5 +-
.../runtime/io/ValidatingCheckpointHandler.java | 14 +-
...tStreamTaskChainedSourcesCheckpointingTest.java | 2 +-
.../tasks/StreamTaskMailboxTestHarnessBuilder.java | 5 +-
.../tasks/SubtaskCheckpointCoordinatorTest.java | 5 +-
.../UnalignedCheckpointCompatibilityITCase.java | 1 +
.../checkpointing/UnalignedCheckpointTestBase.java | 1 +
44 files changed, 1121 insertions(+), 286 deletions(-)
