[GitHub] [flink] xintongsong commented on a diff in pull request #22733: [FLINK-31642][network] Introduce the MemoryTierConsumerAgent

xintongsong commented on code in PR #22733: URL: https://github.com/apache/flink/pull/22733#discussion_r1233228687 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageConsumerClient.java: ## @@ -43,8 +68,25 @@ public

[GitHub] [flink] xintongsong commented on a diff in pull request #22733: [FLINK-31642][network] Introduce the MemoryTierConsumerAgent

xintongsong commented on code in PR #22733: URL: https://github.com/apache/flink/pull/22733#discussion_r1228923781 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/memory/MemoryTierConsumerAgent.java: ## @@ -0,0 +1,71 @@ +/* + *

[GitHub] [flink] xintongsong commented on a diff in pull request #22733: [FLINK-31642][network] Introduce the MemoryTierConsumerAgent

xintongsong commented on code in PR #22733: URL: https://github.com/apache/flink/pull/22733#discussion_r1227592647 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/memory/MemoryTierConsumerAgent.java: ## @@ -0,0 +1,62 @@ +/* + *