[GitHub] [flink] lometheus commented on a change in pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

lometheus commented on a change in pull request #17024: URL: https://github.com/apache/flink/pull/17024#discussion_r700666840 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -330,8 +330,16 @@

[GitHub] [flink] lometheus commented on a change in pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

lometheus commented on a change in pull request #17024: URL: https://github.com/apache/flink/pull/17024#discussion_r699305515 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -330,9 +330,12 @@

[GitHub] [flink] lometheus commented on a change in pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

lometheus commented on a change in pull request #17024: URL: https://github.com/apache/flink/pull/17024#discussion_r699305515 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -330,9 +330,12 @@

[GitHub] [flink] lometheus commented on a change in pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

lometheus commented on a change in pull request #17024: URL: https://github.com/apache/flink/pull/17024#discussion_r699310015 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionTest.java ## @@ -692,6 +692,17 @@ public void

[GitHub] [flink] lometheus commented on a change in pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

lometheus commented on a change in pull request #17024: URL: https://github.com/apache/flink/pull/17024#discussion_r699309381 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -330,9 +330,12 @@

[GitHub] [flink] lometheus commented on a change in pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

lometheus commented on a change in pull request #17024: URL: https://github.com/apache/flink/pull/17024#discussion_r699305515 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -330,9 +330,12 @@