[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r600139401 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r600138798 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,265 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r600079683 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,265 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r599709174 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,265 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r599701700 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,265 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r599700030 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,265 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r599698053 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,265 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r599258765 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,275 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598081685 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598080749 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NettyShuffleServiceFactory.java ## @@ -119,13 +121,34 @@ static

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598074585 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598066726 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598066440 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598066194 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598065608 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598065049 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598064923 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598064490 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598064437 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598064204 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598063840 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598063730 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598063366 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598063014 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598062812 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598062094 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadIOExecutor.java ## @@ -0,0 +1,127 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598062016 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadIOExecutor.java ## @@ -0,0 +1,127 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598061122 ## File path: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ## @@ -513,6 +513,30 @@