This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 0009b0c [hotfix][python][docs] Add state API in PyDocs
add f57fc38 [FLINK-23938][checkpoint] Do not resume channels if the
barrier is received via RPC
No new revisions were added by this update.
Summary of changes:
.../network/partition/consumer/TestInputChannel.java | 9 +++++++++
.../AbstractAlignedBarrierHandlerState.java | 9 +++++++--
...bstractAlternatingAlignedBarrierHandlerState.java | 18 ++++++++++++++----
.../AlternatingCollectingBarriersUnaligned.java | 6 ++++--
.../AlternatingWaitingForFirstBarrierUnaligned.java | 6 ++++--
.../io/checkpointing/BarrierHandlerState.java | 3 ++-
.../io/checkpointing/CheckpointBarrierHandler.java | 3 ++-
.../io/checkpointing/CheckpointBarrierTracker.java | 4 +++-
.../io/checkpointing/CheckpointedInputGate.java | 2 +-
.../SingleCheckpointBarrierHandler.java | 5 +++--
.../runtime/tasks/MultipleInputStreamTask.java | 2 +-
.../flink/streaming/runtime/tasks/StreamTask.java | 2 +-
.../io/checkpointing/AlternatingCheckpointsTest.java | 12 ++++++++----
.../io/checkpointing/InputProcessorUtilTest.java | 3 ++-
.../UnalignedCheckpointsCancellationTest.java | 3 ++-
.../io/checkpointing/UnalignedCheckpointsTest.java | 6 +++---
.../tasks/StreamTaskFinalCheckpointsTest.java | 20 +++++++++++++++++---
17 files changed, 83 insertions(+), 30 deletions(-)
