This is an automated email from the ASF dual-hosted git repository.
nkruber pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e7ac3ba [FLINK-10324] Replace
ZooKeeperStateHandleStore#getAllSortedByNameAndLock by getAllAndLock
new a5e1d40 [hotfix][checkstyle] Remove suppression for
runtime/network.partition
new bbb8b0a [hotfix][network] ensure deserialization buffer capacity for
the whole record length
new 213e085 [hotfix][network] some minor improvements around the network
stack
new 51f53d8 [hotfix][network] minor optimisations and clarifications
around BufferBuilder and BufferConsumer
new 9d2b74b [hotfix][network] adapt InputGateConcurrentTest to really
follow our guarantees
new d9c49c1 [hotfix][network][tests] add readView.nextBufferIsEvent to
assertNextBufferOrEvent()
new b728253 [hotfix][network][tests] use assertNextBuffer etc in
PipelinedSubpartitionTest
new a9e5f70 [FLINK-10331][network] reduce unnecessary flushing
new 72d522e [hotfix][network][tests] split PipelinedSubpartitionTest for
better initialization
new bda07fc [hotfix][network] use ConcurrentMap#putIfAbsent and Lambdas
for partition request handlers
new c15ba1c [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 | 23 +-
.../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, 542 insertions(+), 449 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionWithReadViewTest.java
