You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2021/01/30 10:02:14 UTC
[flink] branch master updated (30f6964 -> a4ccc6e)

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 30f6964  [FLINK-21164][rest] Delete temporary jars
     add a6b909c  [FLINK-21104][network] Adding task name to logged network buffers
     add 393f64f  [FLINK-21104][task] Ease debugging.
     add df1a70a  [FLINK-21104][tests] Fix UnalignedCheckpointITCase not completing when there is a failure while finishing.
     add a4ae50d  [FLINK-21104][network] Do not enqueue released channels into the input gate.
     add abcdeec  [FLINK-21104][network] Fix handling of obsolete CheckpointBarriers in UnalignedCheckpoints
     add a237447  [FLINK-20654][network] Fix incorrect spilling/persisting logic in RemoteInputChannel
     add a4ccc6e  [FLINK-21104][network] Priority notification after cancellation.

No new revisions were added by this update.

Summary of changes:
 .../channel/RecoveredChannelStateHandler.java      |   2 -
 .../io/network/logger/NetworkActionsLogger.java    |  23 +-
 .../network/partition/PipelinedSubpartition.java   |   5 +-
 .../partition/consumer/ChannelStatePersister.java  |  35 ++-
 .../partition/consumer/LocalInputChannel.java      |   9 +-
 .../partition/consumer/RecoveredInputChannel.java  |   6 +
 .../partition/consumer/RemoteInputChannel.java     |  49 +++-
 .../partition/consumer/SingleInputGate.java        |   6 +
 .../consumer/ChannelStatePersisterTest.java        |  94 ++++---
 .../partition/consumer/SingleInputGateTest.java    |  17 ++
 .../partition/consumer/TestInputChannel.java       |   7 +-
 .../io/checkpointing/CheckpointedInputGate.java    |   4 +-
 .../runtime/tasks/mailbox/TaskMailboxImpl.java     |  15 +-
 .../checkpointing/AlternatingControllerTest.java   |   2 +-
 .../checkpointing/CheckpointedInputGateTest.java   | 278 ++++++++++++++++++++-
 .../checkpointing/UnalignedCheckpointITCase.java   |  13 +-
 .../checkpointing/UnalignedCheckpointTestBase.java |  68 ++++-
 17 files changed, 546 insertions(+), 87 deletions(-)