This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8bd62ec [FLINK-25786][network] Adjust the generation of subpartition
data storage order for sort-shuffle from random shuffle to random shift
add f4fd4f8 [FLINK-25035][runtime] Move consumedSubpartitionIndex from
SingleInputGate to InputChannel
add 5c2ec72 [FLINK-25035][runtime] SingleInputGate supports consuming
subpartition range
No new revisions were added by this update.
Summary of changes:
.../runtime/deployment/SubpartitionIndexRange.java | 2 +-
.../network/partition/consumer/InputChannel.java | 23 +-
.../partition/consumer/LocalInputChannel.java | 15 +-
.../consumer/LocalRecoveredInputChannel.java | 3 +
.../partition/consumer/RecoveredInputChannel.java | 4 +-
.../partition/consumer/RemoteInputChannel.java | 16 +-
.../consumer/RemoteRecoveredInputChannel.java | 3 +
.../partition/consumer/SingleInputGate.java | 139 +++++++----
.../partition/consumer/SingleInputGateFactory.java | 50 +++-
.../partition/consumer/UnknownInputChannel.java | 15 +-
...editBasedPartitionRequestClientHandlerTest.java | 11 +-
.../NettyMessageClientDecoderDelegateTest.java | 2 +-
.../NettyMessageClientSideSerializationTest.java | 2 +-
.../netty/NettyPartitionRequestClientTest.java | 16 +-
.../network/partition/InputGateFairnessTest.java | 10 +-
.../consumer/InputBuffersMetricsTest.java | 2 +-
.../partition/consumer/InputChannelBuilder.java | 11 +
.../partition/consumer/InputChannelTest.java | 3 +-
.../partition/consumer/LocalInputChannelTest.java | 44 ++--
.../consumer/RecoveredInputChannelTest.java | 3 +-
.../partition/consumer/RemoteInputChannelTest.java | 83 +++----
.../partition/consumer/SingleInputGateBuilder.java | 10 +-
.../partition/consumer/SingleInputGateTest.java | 254 +++++++++++++++++----
.../partition/consumer/TestInputChannel.java | 3 +-
.../benchmark/SingleInputGateBenchmarkFactory.java | 16 +-
.../checkpointing/CheckpointedInputGateTest.java | 6 +-
26 files changed, 522 insertions(+), 224 deletions(-)
