You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by dw...@apache.org on 2021/05/21 10:44:48 UTC

[flink] branch master updated (1938f639 -> f041516)

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 1938f639 [FLINK-22713][docs] Correct document syntax errors in Kafka page (#15957)
     add f041516  [FLINK-22638] Keep channels blocked on alignment timeout

No new revisions were added by this update.

Summary of changes:
 ...tractAlternatingAlignedBarrierHandlerState.java |  9 +++--
 .../AlternatingCollectingBarriers.java             |  7 +++-
 ...=> AlternatingCollectingBarriersUnaligned.java} | 33 +++++++++-------
 .../AlternatingWaitingForFirstBarrier.java         | 10 ++---
 ...lternatingWaitingForFirstBarrierUnaligned.java} | 44 ++++++++++++----------
 .../runtime/io/checkpointing/ChannelState.java     | 11 ++++++
 .../io/checkpointing/CollectingBarriers.java       |  1 +
 .../SingleCheckpointBarrierHandler.java            |  4 +-
 .../io/checkpointing/WaitingForFirstBarrier.java   |  1 +
 .../checkpointing/AlternatingCheckpointsTest.java  | 39 ++++---------------
 10 files changed, 82 insertions(+), 77 deletions(-)
 rename flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/{CollectingBarriersUnaligned.java => AlternatingCollectingBarriersUnaligned.java} (68%)
 rename flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/{WaitingForFirstBarrierUnaligned.java => AlternatingWaitingForFirstBarrierUnaligned.java} (66%)