This is an automated email from the ASF dual-hosted git repository.
nkruber pushed a change to branch release-1.5
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5852a25 [FLINK-10259] [table] Fix identification of key attributes
for GroupWindows.
new 542a35a [hotfix][checkstyle] Remove suppression for
runtime/network.partition
new 11ada4b [hotfix][network] ensure deserialization buffer capacity for
the whole record length
new 26f4355 [hotfix][network] some minor improvements around the network
stack
new adaab8e [hotfix][network] minor optimisations and clarifications
around BufferBuilder and BufferConsumer
new b75e865 [hotfix][network] adapt InputGateConcurrentTest to really
follow our guarantees
new 1abe6aa [hotfix][network][tests] add readView.nextBufferIsEvent to
assertNextBufferOrEvent()
new fb18c28 [hotfix][network][tests] use assertNextBuffer etc in
PipelinedSubpartitionTest
new 16ea186 [FLINK-10331][network] reduce unnecessary flushing
new 915db25 [hotfix][network][tests] split PipelinedSubpartitionTest for
better initialization
The 9 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 | 3 +-
.../netty/PartitionRequestClientHandler.java | 3 +-
.../partition/PartitionNotFoundException.java | 3 +
.../network/partition/PipelinedSubpartition.java | 52 ++--
.../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 +-
39 files changed, 529 insertions(+), 420 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionWithReadViewTest.java
