This is an automated email from the ASF dual-hosted git repository.
guoweijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 4006de97352 [FLINK-31549][jdbc-driver] Add jdbc driver docs
add 598e1b9b94e [FLINK-31642][network] Implement the
MemoryTierConsumerAgent
add 67dd69247b8 [FLINK-31642][network] Introduce the
MemoryTierConsumerAgent to TieredStorageConsumerClient
add a83dd938592 [FLINK-31642][network] Enable NettyConnectionReader to
notify upstream required segment id
No new revisions were added by this update.
Summary of changes:
.../io/network/NettyShuffleEnvironment.java | 10 +-
.../io/network/NetworkSequenceViewReader.java | 7 +
.../runtime/io/network/PartitionRequestClient.java | 8 +
.../CreditBasedSequenceNumberingViewReader.java | 5 +
.../runtime/io/network/netty/NettyMessage.java | 49 ++++++
.../network/netty/NettyPartitionRequestClient.java | 20 +++
.../io/network/netty/PartitionRequestQueue.java | 16 ++
.../netty/PartitionRequestServerHandler.java | 4 +
.../network/partition/consumer/InputChannel.java | 5 +-
.../partition/consumer/LocalInputChannel.java | 7 +
.../partition/consumer/RemoteInputChannel.java | 7 +
.../partition/consumer/SingleInputGate.java | 61 ++++++-
.../partition/consumer/SingleInputGateFactory.java | 35 +++-
.../tiered/netty/NettyConnectionReaderImpl.java | 6 +-
.../tiered/netty/TieredStorageNettyService.java | 10 +-
.../netty/TieredStorageNettyServiceImpl.java | 193 +++++++++++++++------
.../storage/TieredStorageConsumerClient.java | 78 ++++++++-
...rClient.java => TieredStorageConsumerSpec.java} | 25 +--
.../hybrid/tiered/tier/TierConsumerAgent.java | 16 +-
.../partition/hybrid/tiered/tier/TierFactory.java | 7 +-
.../tier/memory/MemoryTierConsumerAgent.java | 85 +++++++++
.../tiered/tier/memory/MemoryTierFactory.java | 10 +-
.../io/network/TestingPartitionRequestClient.java | 3 +
.../network/partition/InputGateFairnessTest.java | 2 +
.../partition/consumer/RemoteInputChannelTest.java | 11 ++
.../partition/consumer/SingleInputGateBuilder.java | 4 +-
.../partition/consumer/SingleInputGateTest.java | 3 +-
.../tiered/netty/TestingNettyConnectionReader.java | 56 ++++++
.../netty/TestingTieredStorageNettyService.java | 16 +-
.../netty/TieredStorageConsumerClientTest.java | 73 ++++++++
.../hybrid/tiered/storage/TestingTierFactory.java | 123 +++++++++++++
.../StreamNetworkBenchmarkEnvironment.java | 3 +-
32 files changed, 852 insertions(+), 106 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/{TieredStorageMasterClient.java
=> TieredStorageConsumerSpec.java} (56%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/memory/MemoryTierConsumerAgent.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/TestingNettyConnectionReader.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/TieredStorageConsumerClientTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TestingTierFactory.java
