[flink] branch master updated: [hotfix][refactor] Reuse existing method in SortMergeResultPartition

[yingjie]

This is an automated email from the ASF dual-hosted git repository.

yingjie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 7adbd032e7f [hotfix][refactor] Reuse existing method in 
SortMergeResultPartition
7adbd032e7f is described below

commit 7adbd032e7f4c1c6c48e5db3dcae57a6e4ccaa1a
Author: kevin.cyj <kevin....@alibaba-inc.com>
AuthorDate: Sun Apr 23 11:06:35 2023 +0800

    [hotfix][refactor] Reuse existing method in SortMergeResultPartition
---
 .../flink/runtime/io/network/partition/SortMergeResultPartition.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java
index 52637051983..9aee849d750 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java
@@ -344,7 +344,7 @@ public class SortMergeResultPartition extends 
ResultPartition {
                 
freeSegments.add(checkNotNull(bufferPool.requestMemorySegmentBlocking()));
             }
         } catch (InterruptedException exception) {
-            freeSegments.forEach(bufferPool::recycle);
+            releaseFreeBuffers();
             throw new IOException("Failed to allocate buffers for result 
partition.", exception);
         }
     }