This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from cd7b212 [hotfix][coordination] Remove outdated comment
new ee07fff [hotfix] Minor cleanups
new f0dc60e [hotfix] [network] Rename BoundedBlockingSubpartitionReader
'memory' parameter
new d88882c [FLINK-12986] [network] Add different implementations to
store/serve the data from the BoundedBlockingSubpartition
new 4c93e68 [hotfix] [tests] Remove usage of Assume in BoundedDataTests
to avoid warnings during build/testing
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/flink/util/MemoryArchitecture.java | 77 +++++++
.../apache/flink/util/MemoryArchitectureTest.java | 14 +-
.../io/network/buffer/BufferPoolFactory.java | 5 +
.../io/network/buffer/NetworkBufferPool.java | 5 +
.../partition/BoundedBlockingSubpartition.java | 85 ++++---
.../BoundedBlockingSubpartitionReader.java | 22 +-
.../partition/BoundedBlockingSubpartitionType.java | 75 +++++++
.../runtime/io/network/partition/BoundedData.java | 80 +++++++
.../network/partition/BufferReaderWriterUtil.java | 250 +++++++++++++++++++++
.../io/network/partition/BufferToByteBuffer.java | 130 -----------
.../network/partition/FileChannelBoundedData.java | 160 +++++++++++++
.../FileChannelMemoryMappedBoundedData.java | 210 +++++++++++++++++
...edBuffers.java => MemoryMappedBoundedData.java} | 100 +++++----
.../network/partition/ResultPartitionFactory.java | 33 ++-
.../partition/BoundedBlockingSubpartitionTest.java | 66 ++++--
.../BoundedBlockingSubpartitionWriteReadTest.java | 40 +++-
...edBuffersTest.java => BoundedDataTestBase.java} | 119 ++++++----
.../partition/BufferReaderWriterUtilTest.java | 203 +++++++++++++++++
.../network/partition/BufferToByteBufferTest.java | 80 -------
.../partition/FileChannelBoundedDataTest.java} | 25 ++-
.../FileChannelMemoryMappedBoundedDataTest.java} | 33 +--
.../partition/MemoryMappedBoundedDataTest.java} | 25 ++-
22 files changed, 1420 insertions(+), 417 deletions(-)
create mode 100755
flink-core/src/main/java/org/apache/flink/util/MemoryArchitecture.java
copy
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBInitResetTest.java
=> flink-core/src/test/java/org/apache/flink/util/MemoryArchitectureTest.java
(72%)
mode change 100644 => 100755
mode change 100644 => 100755
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferPoolFactory.java
mode change 100644 => 100755
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
mode change 100644 => 100755
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartition.java
mode change 100644 => 100755
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartitionReader.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartitionType.java
create mode 100755
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedData.java
create mode 100755
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferReaderWriterUtil.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferToByteBuffer.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/FileChannelBoundedData.java
create mode 100755
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/FileChannelMemoryMappedBoundedData.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/{MemoryMappedBuffers.java
=> MemoryMappedBoundedData.java} (73%)
mode change 100644 => 100755
mode change 100644 => 100755
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionFactory.java
rename
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/{MemoryMappedBuffersTest.java
=> BoundedDataTestBase.java} (52%)
mode change 100644 => 100755
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/BufferReaderWriterUtilTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/BufferToByteBufferTest.java
copy
flink-runtime/src/{main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionProvider.java
=>
test/java/org/apache/flink/runtime/io/network/partition/FileChannelBoundedDataTest.java}
(60%)
mode change 100644 => 100755
copy
flink-runtime/src/{main/java/org/apache/flink/runtime/blob/VoidBlobStore.java
=>
test/java/org/apache/flink/runtime/io/network/partition/FileChannelMemoryMappedBoundedDataTest.java}
(58%)
mode change 100644 => 100755
copy
flink-runtime/src/{main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionProvider.java
=>
test/java/org/apache/flink/runtime/io/network/partition/MemoryMappedBoundedDataTest.java}
(59%)
mode change 100644 => 100755
