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 446e711 [hotfix][travis] Retain existing MAVEN_OPTS in Travis maven
setup
new b50896a [FLINK-12378][docs] Consolidate FileSystem Documentation
new 4dae94d [FLINK-8513][docs] Add documentation for connecting to
non-AWS S3 endpoints
new 7d45b75 [FLINK-10249][docs] Document hadoop/presto s3 file system
configuration forwarding
new 4c0bbc4 [hotfix][docs] Some fixes to FileSystem Documentation
new d14fc9e [hotfix] [docs] Minor cleanup in filesystem docs
new 754cd71 [FLINK-12388][docs] Update the production readiness checklist
new 541e413 [hotfix] Expand JavaDoc of MemorySegment.wrap()
new 826daab [hotfix] [network] Release unpooled buffer for events.
new e94ec4f [hotfix] [tests] Remove unnecessary timeouts from
SingleInputGate Tests
new dfd08ab [hotfix] [tests] Network and Partition Tests pass in Testing
IOManager rather than dysfunctional mock
new 8a76952 [hotfix] [tests] Consolidate mocking of ResultPartition in
one utility class
new e5a6a94 [hotfix] [tests] Remove redundant test assertions
new 422f7b5 [hotfix] [tests] Move utility methods into correct test class.
new a7cf243 [FLINK-12070] [network] Change Bounded Blocking Subpartition
Implementation to Memory Mapped Files
The 14 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:
docs/ops/deployment/aws.md | 387 ----------
docs/ops/deployment/aws.zh.md | 387 ----------
docs/ops/deployment/oss.md | 233 ------
docs/ops/deployment/oss.zh.md | 233 ------
docs/ops/filesystems.md | 177 -----
docs/ops/filesystems.zh.md | 177 -----
docs/ops/filesystems/common.md | 69 ++
docs/ops/filesystems/common.zh.md | 69 ++
docs/ops/filesystems/index.md | 94 +++
docs/ops/filesystems/index.zh.md | 94 +++
docs/ops/filesystems/oss.md | 78 ++
docs/ops/filesystems/oss.zh.md | 78 ++
docs/ops/filesystems/s3.md | 136 ++++
docs/ops/filesystems/s3.zh.md | 136 ++++
docs/ops/production_ready.md | 87 +--
docs/ops/production_ready.zh.md | 88 +--
docs/redirects/filesystems.md | 24 +
docs/redirects/oss.md | 24 +
.../apache/flink/core/memory/MemorySegment.java | 3 +-
.../flink/core/memory/MemorySegmentFactory.java | 14 +
.../runtime/io/network/buffer/BufferConsumer.java | 11 +-
.../partition/BoundedBlockingSubpartition.java | 274 +++++++
.../BoundedBlockingSubpartitionReader.java | 144 ++++
.../io/network/partition/BufferToByteBuffer.java | 130 ++++
.../io/network/partition/MemoryMappedBuffers.java | 279 +++++++
.../runtime/io/network/partition/PageSizeUtil.java | 113 +++
.../network/partition/PipelinedSubpartition.java | 70 ++
.../io/network/partition/ResultPartition.java | 38 +-
.../io/network/partition/ResultSubpartition.java | 83 +--
.../network/partition/SpillableSubpartition.java | 312 --------
.../partition/SpillableSubpartitionView.java | 280 --------
.../network/partition/SpilledSubpartitionView.java | 303 --------
.../partition/consumer/SingleInputGate.java | 8 +-
.../runtime/io/disk/iomanager/NoOpIOManager.java | 73 ++
.../runtime/io/network/NetworkEnvironmentTest.java | 21 +-
.../io/network/buffer/BufferBuilderTestUtils.java | 29 +
.../partition/BoundedBlockingSubpartitionTest.java | 105 +++
.../BoundedBlockingSubpartitionWriteReadTest.java | 199 +++++
.../network/partition/BufferToByteBufferTest.java | 80 +++
.../network/partition/MemoryMappedBuffersTest.java | 162 +++++
.../io/network/partition/PartitionTestUtils.java | 74 ++
.../partition/PipelinedSubpartitionTest.java | 47 +-
.../PipelinedSubpartitionWithReadViewTest.java | 93 ++-
.../io/network/partition/ResultPartitionTest.java | 38 +-
.../partition/SpillableSubpartitionTest.java | 800 ---------------------
.../io/network/partition/SubpartitionTestBase.java | 197 ++---
.../partition/consumer/SingleInputGateTest.java | 8 +-
.../partition/consumer/TestInputChannel.java | 32 +-
48 files changed, 2928 insertions(+), 3663 deletions(-)
delete mode 100644 docs/ops/deployment/oss.md
delete mode 100644 docs/ops/deployment/oss.zh.md
delete mode 100644 docs/ops/filesystems.md
delete mode 100644 docs/ops/filesystems.zh.md
create mode 100644 docs/ops/filesystems/common.md
create mode 100644 docs/ops/filesystems/common.zh.md
create mode 100644 docs/ops/filesystems/index.md
create mode 100644 docs/ops/filesystems/index.zh.md
create mode 100644 docs/ops/filesystems/oss.md
create mode 100644 docs/ops/filesystems/oss.zh.md
create mode 100644 docs/ops/filesystems/s3.md
create mode 100644 docs/ops/filesystems/s3.zh.md
create mode 100644 docs/redirects/filesystems.md
create mode 100644 docs/redirects/oss.md
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartition.java
create mode 100644
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/BufferToByteBuffer.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/MemoryMappedBuffers.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PageSizeUtil.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartition.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/disk/iomanager/NoOpIOManager.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartitionTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartitionWriteReadTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/BufferToByteBufferTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/MemoryMappedBuffersTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PartitionTestUtils.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java
