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

2023-06-08 Thread via GitHub
reswqa commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1223798313 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyConnectionReaderTest.java: ## @@ -0,0 +1,203 @@ +/* + * Licensed to

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

2023-06-08 Thread via GitHub
reswqa commented on code in PR #22342: URL: https://github.com/apache/flink/pull/22342#discussion_r1222589878 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputChannel.java: ## @@ -311,6 +311,16 @@ public long unsynchronizedGetSizeOfQueue