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 d857cfda152 [FLINK-30585][flamegraph] Collect the flame graph of a
single subtask instead of all subtasks when viewing the flame graph of a single
subtask
add 6398abcbff0 [FLINK-31636][network] Introduce the NettyService framework
add a58c1980912 [FLINK-31636][network] Introduce the EndOfSegmentEvent
add 4e82ab0c37a [FLINK-31636][network] Introduce the
TieredStoreResultSubpartitionView
No new revisions were added by this update.
Summary of changes:
.../runtime/io/network/api/EndOfSegmentEvent.java | 66 ++++++
.../network/api/serialization/EventSerializer.java | 7 +
.../flink/runtime/io/network/buffer/Buffer.java | 5 +-
.../network/partition/ResultSubpartitionView.java | 8 +
.../network/partition/consumer/InputChannel.java | 12 +-
.../partition/consumer/LocalInputChannel.java | 2 +-
.../partition/consumer/RecoveredInputChannel.java | 2 +-
.../partition/consumer/RemoteInputChannel.java | 2 +-
.../hybrid/tiered/netty/NettyConnectionId.java | 58 +++++
.../hybrid/tiered/netty/NettyConnectionReader.java | 36 ++++
...nectionReaderAvailabilityAndPriorityHelper.java | 44 ++++
.../tiered/netty/NettyConnectionReaderImpl.java | 77 +++++++
.../hybrid/tiered/netty/NettyConnectionWriter.java | 59 ++++++
.../tiered/netty/NettyConnectionWriterImpl.java | 64 ++++++
.../hybrid/tiered/netty/NettyPayload.java | 113 ++++++++++
.../hybrid/tiered/netty/NettyServiceProducer.java | 48 +++++
.../tiered/netty/TieredStorageNettyService.java | 51 +++++
.../netty/TieredStorageNettyServiceImpl.java | 187 +++++++++++++++++
.../netty/TieredStoreResultSubpartitionView.java | 233 +++++++++++++++++++++
.../tiered/shuffle/TieredResultPartition.java | 12 +-
.../api/serialization/EventSerializerTest.java | 2 +
.../partition/consumer/InputChannelTest.java | 3 +-
.../partition/consumer/TestInputChannel.java | 19 +-
.../tiered/netty/NettyConnectionReaderTest.java | 191 +++++++++++++++++
.../tiered/netty/NettyConnectionWriterTest.java | 76 +++++++
.../hybrid/tiered/netty/NettyPayloadTest.java | 82 ++++++++
...nectionReaderAvailabilityAndPriorityHelper.java | 76 +++++++
.../tiered/netty/TestingNettyServiceProducer.java | 80 +++++++
.../TieredStoreResultSubpartitionViewTest.java | 197 +++++++++++++++++
.../tiered/shuffle/TieredResultPartitionTest.java | 4 +-
30 files changed, 1805 insertions(+), 11 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/EndOfSegmentEvent.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyConnectionId.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyConnectionReader.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyConnectionReaderAvailabilityAndPriorityHelper.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyConnectionReaderImpl.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyConnectionWriter.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyConnectionWriterImpl.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyPayload.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyServiceProducer.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/TieredStorageNettyService.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/TieredStorageNettyServiceImpl.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/TieredStoreResultSubpartitionView.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyConnectionReaderTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyConnectionWriterTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyPayloadTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/TestingNettyConnectionReaderAvailabilityAndPriorityHelper.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/TestingNettyServiceProducer.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/TieredStoreResultSubpartitionViewTest.java
