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

Posted to commits@flink.apache.org by yi...@apache.org on 2022/08/04 16:49:24 UTC

[flink] branch master updated (5405239dec0 -> 4e790646c37)

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

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


    from 5405239dec0 [FLINK-28419][table] Add runtime provider interface for full caching lookup + implement Periodic and Timed cache reload triggers
     add 4e790646c37 Revert "[FLINK-28373][network] Read a full buffer of data per file IO read request for sort-shuffle"

No new revisions were added by this update.

Summary of changes:
 .../runtime/io/network/buffer/CompositeBuffer.java | 233 ---------------------
 .../buffer/ReadOnlySlicedNetworkBuffer.java        |  10 +-
 .../runtime/io/network/netty/NettyMessage.java     |   7 +-
 .../network/partition/PartitionedFileReader.java   | 130 ------------
 .../partition/SortMergeSubpartitionReader.java     |  17 +-
 .../partition/consumer/LocalInputChannel.java      |   7 +-
 .../network/buffer/ReadOnlySlicedBufferTest.java   |  20 +-
 .../SortMergeResultPartitionReadSchedulerTest.java |  73 ++++---
 .../partition/SortMergeResultPartitionTest.java    |  34 +--
 .../partition/SortMergeSubpartitionReaderTest.java | 103 +++++----
 10 files changed, 125 insertions(+), 509 deletions(-)
 delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/CompositeBuffer.java