[GitHub] [flink] wsry commented on a diff in pull request #20459: [FLINK-28823][network] Enlarge the max requested buffers for SortMergeResultPartitionReadScheduler

[GitBox <gi...@apache.org>]

wsry commented on code in PR #20459:
URL: https://github.com/apache/flink/pull/20459#discussion_r939659766


##########
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java:
##########
@@ -85,8 +85,8 @@ class SortMergeResultPartitionReadScheduler implements Runnable, BufferRecycler
     /** Executor to run the shuffle data reading task. */
     private final Executor ioExecutor;
 
-    /** Maximum number of buffers can be allocated by this partition reader. */
-    private final int maxRequestedBuffers;
+    /** Number of subpartitions in the target result partition. */
+    private final int numSubpartitions;

Review Comment:
   This filed seems not used so can be removed.



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org