subject:"\[GitHub\] \[flink\] xintongsong commented on a diff in pull request #22652\: \[FLINK\-31640\]\[network\] Write the accumulated buffers to the right storage tier"

[GitHub] [flink] xintongsong commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

2023-06-01 Thread via GitHub

xintongsong commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1212751146 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageProducerClient.java: ## @@ -80,13 +107,23 @@ public

[GitHub] [flink] xintongsong commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

2023-05-31 Thread via GitHub

xintongsong commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1212515884 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageProducerClient.java: ## @@ -119,7 +149,60 @@ private