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
