This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b31f4bd [FLINK-22808][state/changelog] Log metadata
new 7281f2b [hotfix] Refactor the initialization of StreamTask to expose
CheckpointBarrierHandler
new a8b5649 [FLINK-21085][runtime] SingleInputGate supports acquiring
unfinished channels
new 0119ac0 [FLINK-21085] Allows taking snapshot with closed operators if
enabled checkpoints after tasks finished
new 415e07e [FLINK-21085][runtime][checkpoint] Allows triggering
checkpoint for non-source tasks
The 4 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:
.../partition/consumer/IndexedInputGate.java | 4 +
.../partition/consumer/SingleInputGate.java | 16 +++
.../runtime/taskmanager/InputGateWithMetrics.java | 6 ++
.../partition/consumer/SingleInputGateTest.java | 44 ++++++++
.../io/checkpointing/InputProcessorUtil.java | 54 ----------
.../runtime/tasks/MultipleInputStreamTask.java | 15 +++
.../runtime/tasks/OneInputStreamTask.java | 45 ++++++--
.../flink/streaming/runtime/tasks/StreamTask.java | 55 +++++++++-
.../tasks/SubtaskCheckpointCoordinator.java | 6 ++
.../tasks/SubtaskCheckpointCoordinatorImpl.java | 13 ++-
.../runtime/tasks/TwoInputStreamTask.java | 30 +++++-
.../streaming/runtime/io/MockIndexedInputGate.java | 6 ++
.../flink/streaming/runtime/io/MockInputGate.java | 6 ++
.../AlignedCheckpointsMassiveRandomTest.java | 6 ++
.../io/checkpointing/InputProcessorUtilTest.java | 19 ++--
...tStreamTaskChainedSourcesCheckpointingTest.java | 55 ++++++++++
.../runtime/tasks/MultipleInputStreamTaskTest.java | 114 ++++++++++++++++++++-
.../streaming/runtime/tasks/StreamTaskTest.java | 96 +++++++++++++++++
.../tasks/TestSubtaskCheckpointCoordinator.java | 3 +
19 files changed, 512 insertions(+), 81 deletions(-)
