[GitHub] [flink] WencongLiu commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

WencongLiu commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1223868769 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyConnectionReaderTest.java: ## @@ -0,0 +1,203 @@ +/* + * License

[GitHub] [flink] WencongLiu commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

WencongLiu commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1223768558 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyConnectionReaderTest.java: ## @@ -0,0 +1,203 @@ +/* + * License

[GitHub] [flink] WencongLiu commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

WencongLiu commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1223745155 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyConnectionWriterImpl.java: ## @@ -0,0 +1,60 @@ +/* + * Licensed

[GitHub] [flink] WencongLiu commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

WencongLiu commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1212845100 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/EndOfSegmentEvent.java: ## @@ -0,0 +1,64 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] WencongLiu commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

WencongLiu commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1209306292 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/ConsumerNettyService.java: ## @@ -0,0 +1,65 @@ +/* + * Licensed to t

[GitHub] [flink] WencongLiu commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

WencongLiu commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1209305502 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/EndOfSegmentEvent.java: ## @@ -0,0 +1,64 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] WencongLiu commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

WencongLiu commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1184909916 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/BufferContext.java: ## @@ -0,0 +1,66 @@ +/* + * Licensed to the Ap

[GitHub] [flink] WencongLiu commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

WencongLiu commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1184909667 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/BufferContext.java: ## @@ -0,0 +1,66 @@ +/* + * Licensed to the Ap

[GitHub] [flink] WencongLiu commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

WencongLiu commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1184909295 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/BufferContext.java: ## @@ -0,0 +1,66 @@ +/* + * Licensed to the Ap

[GitHub] [flink] WencongLiu commented on a diff in pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

WencongLiu commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1184908682 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/BufferContext.java: ## @@ -0,0 +1,66 @@ +/* + * Licensed to the Ap