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

Posted to commits@flink.apache.org by zh...@apache.org on 2019/10/28 05:37:32 UTC

[flink] branch master updated (f61d223 -> 60ce77a)

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

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


    from f61d223  [FLINK-14227][docs-zh] Translate "Checkpointing" page to Chinese
     add a385254  [hotfix][runtime] Implement AvailabilityHelper for providing resetAvailable/Unavailble functions for InputGate
     add ad70e06  [FLINK-14396][network] Implement rudimentary non-blocking network output
     add 60ce77a  [hotfix][tests] Fix the missing class reference in LocalInputChannelTest

No new revisions were added by this update.

Summary of changes:
 .../flink/runtime/io/AvailabilityProvider.java     | 44 ++++++++++++
 .../io/network/api/writer/RecordWriter.java        |  9 ++-
 .../network/api/writer/ResultPartitionWriter.java  |  9 +++
 .../runtime/io/network/buffer/BufferProvider.java  |  4 +-
 .../runtime/io/network/buffer/LocalBufferPool.java | 83 ++++++++++++++++------
 .../io/network/partition/ResultPartition.java      |  6 ++
 .../io/network/partition/consumer/InputGate.java   | 11 +--
 .../partition/consumer/SingleInputGate.java        | 14 ++--
 .../network/partition/consumer/UnionInputGate.java | 16 ++---
 ...bleNotifyingResultPartitionWriterDecorator.java |  6 ++
 .../AbstractCollectingResultPartitionWriter.java   |  7 ++
 .../io/network/api/writer/RecordWriterTest.java    | 62 ++++++++++++++++
 .../runtime/io/network/buffer/NoOpBufferPool.java  |  6 ++
 .../partition/consumer/LocalInputChannelTest.java  |  1 +
 .../io/network/util/TestPooledBufferProvider.java  |  6 ++
 .../CheckpointBarrierAlignerMassiveRandomTest.java |  2 +-
 .../flink/streaming/runtime/io/MockInputGate.java  |  4 +-
 17 files changed, 239 insertions(+), 51 deletions(-)