[GitHub] [flink] xintongsong commented on a diff in pull request #22804: [FLINK-31644][network] Implement the disk tier producer for the tiered storage

2023-06-25 Thread via GitHub
xintongsong commented on code in PR #22804: URL: https://github.com/apache/flink/pull/22804#discussion_r1240656333 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/PartitionFileIndex.java: ## @@ -0,0 +1,218 @@ +/* + * Licensed to

[GitHub] [flink] xintongsong commented on a diff in pull request #22804: [FLINK-31644][network] Implement the disk tier producer for the tiered storage

2023-06-21 Thread via GitHub
xintongsong commented on code in PR #22804: URL: https://github.com/apache/flink/pull/22804#discussion_r1236252253 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/PartitionFileWriter.java: ## @@ -0,0 +1,107 @@ +/* + * Licensed to

[GitHub] [flink] xintongsong commented on a diff in pull request #22804: [FLINK-31644][network] Implement the disk tier producer for the tiered storage

2023-06-18 Thread via GitHub
xintongsong commented on code in PR #22804: URL: https://github.com/apache/flink/pull/22804#discussion_r1233232708 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/file/SegmentNettyPayload.java: ## @@ -0,0 +1,55 @@ +/* + *