This is an automated email from the ASF dual-hosted git repository.
nkruber pushed a change to branch release-1.6
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a58fa98 [FLINK-9061] [s3 presto] Add entropy injection to S3 file
system
new 40fc6b6 [hotfix][checkstyle] Remove suppression for
runtime/network.partition
new 6c77b31 [hotfix][network] ensure deserialization buffer capacity for
the whole record length
new 9e3d36a [hotfix][network] some minor improvements around the network
stack
new e075be2 [hotfix][network] minor optimisations and clarifications
around BufferBuilder and BufferConsumer
new e059c5d [hotfix][network] adapt InputGateConcurrentTest to really
follow our guarantees
new e018c69 [hotfix][network][tests] add readView.nextBufferIsEvent to
assertNextBufferOrEvent()
new a8ed18a [hotfix][network][tests] use assertNextBuffer etc in
PipelinedSubpartitionTest
new ef19226 [FLINK-10331][network] reduce unnecessary flushing
new 32bf973 [hotfix][network][tests] split PipelinedSubpartitionTest for
better initialization
new dea8df0 [hotfix][network] use ConcurrentMap#putIfAbsent and Lambdas
for partition request handlers
new 5b2b0f7 [FLINK-10332][network] move data notification out of the
synchronized block
The 11 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:
...SpillingAdaptiveSpanningRecordDeserializer.java | 12 +-
.../runtime/io/network/buffer/BufferBuilder.java | 25 +-
.../runtime/io/network/buffer/BufferConsumer.java | 27 +-
.../runtime/io/network/buffer/NetworkBuffer.java | 2 +-
.../CreditBasedPartitionRequestClientHandler.java | 14 +-
.../netty/PartitionRequestClientHandler.java | 7 +-
.../io/network/netty/PartitionRequestQueue.java | 7 +-
.../partition/PartitionNotFoundException.java | 3 +
.../network/partition/PipelinedSubpartition.java | 76 ++++--
.../io/network/partition/ResultPartition.java | 26 +-
.../ResultPartitionConsumableNotifier.java | 4 +-
.../io/network/partition/ResultPartitionID.java | 2 +-
.../network/partition/ResultPartitionProvider.java | 3 +
.../io/network/partition/ResultPartitionType.java | 7 +-
.../io/network/partition/ResultSubpartition.java | 21 +-
.../network/partition/ResultSubpartitionView.java | 1 +
.../network/partition/consumer/InputChannel.java | 18 +-
.../network/partition/consumer/InputChannelID.java | 3 +
.../io/network/partition/consumer/InputGate.java | 8 +-
.../partition/consumer/InputGateMetrics.java | 2 +-
.../partition/consumer/LocalInputChannel.java | 4 +-
.../partition/consumer/UnknownInputChannel.java | 6 +-
.../network/partition/InputChannelTestUtils.java | 4 +-
.../network/partition/InputGateConcurrentTest.java | 29 +-
.../network/partition/InputGateFairnessTest.java | 16 +-
.../LegacyPartialConsumePipelinedResultTest.java | 13 +-
.../PartialConsumePipelinedResultTest.java | 7 +-
.../partition/PipelinedSubpartitionTest.java | 297 ++-------------------
.../PipelinedSubpartitionWithReadViewTest.java | 276 +++++++++++++++++++
.../partition/ProducerFailedExceptionTest.java | 3 +
.../partition/SpillableSubpartitionTest.java | 20 +-
.../io/network/partition/SubpartitionTestBase.java | 4 +-
.../partition/consumer/InputChannelTest.java | 4 +
.../IteratorWrappingTestSingleInputGate.java | 5 +
.../partition/consumer/LocalInputChannelTest.java | 19 +-
.../partition/consumer/RemoteInputChannelTest.java | 8 +-
.../partition/consumer/SingleInputGateTest.java | 2 +-
.../partition/consumer/TestSingleInputGate.java | 1 +
.../partition/consumer/UnionInputGateTest.java | 5 +-
tools/maven/suppressions-runtime.xml | 4 +-
40 files changed, 545 insertions(+), 450 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionWithReadViewTest.java
