[GitHub] [flink] xintongsong commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

2022-07-07 Thread GitBox
xintongsong commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r915516805 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReaderTest.java: ## @@ -0,0 +1,418 @@ +/* + * Licensed to the A

[GitHub] [flink] xintongsong commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

2022-07-06 Thread GitBox
xintongsong commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r915383242 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/SubpartitionFileReader.java: ## @@ -0,0 +1,43 @@ +/* + * Licensed to the Apache S

[GitHub] [flink] xintongsong commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

2022-07-05 Thread GitBox
xintongsong commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r913578661 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsResultPartitionReadScheduler.java: ## @@ -0,0 +1,396 @@ +/* + * Licensed to the

[GitHub] [flink] xintongsong commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

2022-07-01 Thread GitBox
xintongsong commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r911703471 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsResultPartitionReadScheduler.java: ## @@ -0,0 +1,408 @@ +/* + * Licensed to the

[GitHub] [flink] xintongsong commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

2022-06-29 Thread GitBox
xintongsong commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r91050 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/BufferWithInfo.java: ## @@ -0,0 +1,48 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] xintongsong commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

2022-06-29 Thread GitBox
xintongsong commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r909374249 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsResultPartitionReadScheduler.java: ## @@ -0,0 +1,424 @@ +/* + * Licensed to the

[GitHub] [flink] xintongsong commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

2022-06-29 Thread GitBox
xintongsong commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r909272205 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsResultPartitionReadScheduler.java: ## @@ -0,0 +1,424 @@ +/* + * Licensed to the