[flink] branch release-1.17 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 release-1.17
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.17 by this push:
     new 29975c8f982 [hotfix][refactor] Reuse existing method in 
SortMergeResultPartition
29975c8f982 is described below

commit 29975c8f982fdf163fe14ebd770a74647ecf2782
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 ba84f8b6e0b..b196c813309 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);
         }
     }