[GitHub] [flink] xintongsong commented on a diff in pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

2023-05-20 Thread via GitHub
xintongsong commented on code in PR #22352: URL: https://github.com/apache/flink/pull/22352#discussion_r1199686953 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemoryManagerImpl.java: ## @@ -0,0 +1,279 @@ +/* +

[GitHub] [flink] xintongsong commented on a diff in pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

2023-05-14 Thread via GitHub
xintongsong commented on code in PR #22352: URL: https://github.com/apache/flink/pull/22352#discussion_r1193288010 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemoryManager.java: ## @@ -0,0 +1,96 @@ +/* + *

[GitHub] [flink] xintongsong commented on a diff in pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

2023-05-11 Thread via GitHub
xintongsong commented on code in PR #22352: URL: https://github.com/apache/flink/pull/22352#discussion_r1191854430 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemoryManagerImpl.java: ## @@ -0,0 +1,117 @@ +/* +

[GitHub] [flink] xintongsong commented on a diff in pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

2023-05-01 Thread via GitHub
xintongsong commented on code in PR #22352: URL: https://github.com/apache/flink/pull/22352#discussion_r1181474271 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/CacheFlushManager.java: ## @@ -0,0 +1,100 @@ +/* + * Licensed to