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

Posted to commits@flink.apache.org by ar...@apache.org on 2020/10/06 11:27:08 UTC

[flink] branch master updated (752f7cd -> 61a9973)

This is an automated email from the ASF dual-hosted git repository.

arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 752f7cd  [FLINK-19497][metrics][dropwizard] Override mutator methods in FlinkCounterWrapper
     add b4a5b7a  [FLINK-19027][test][network] Ensure SingleInputGateTest does not swallow exceptions during cleanup.
     add 22d6630  [FLINK-19027][test][network] Set exclusive and floating buffers in UnalignedCheckpointITCase.
     add d8f2276  [FLINK-19027][network] Only assign exclusive buffers to RecoveredRemoteInputChannels when recovering channel state.
     add b072d25  [FLINK-19027][network] Assign exclusive buffers to LocalRecoveredInputChannel.
     add 61a9973  Revert [FLINK-19027][tests] Decrease checkpoint timeout to avoid livelocking in UnalignedCheckpointITCase.

No new revisions were added by this update.

Summary of changes:
 .../consumer/LocalRecoveredInputChannel.java       |  11 +-
 .../partition/consumer/RecoveredInputChannel.java  |  14 ++-
 .../consumer/RemoteRecoveredInputChannel.java      |  21 ++--
 .../partition/consumer/SingleInputGate.java        |  17 ++-
 .../partition/consumer/SingleInputGateFactory.java |   1 +
 .../partition/consumer/InputChannelBuilder.java    |   1 +
 .../partition/consumer/SingleInputGateTest.java    | 127 +++++++++++----------
 .../checkpointing/UnalignedCheckpointITCase.java   |   5 +-
 8 files changed, 120 insertions(+), 77 deletions(-)