(paimon) branch master updated: [core] clear bufferQueue when AsyncPositionOutputStream closing. (#5759)

[lzljs3620320]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 2f2d4c90a0 [core] clear bufferQueue when AsyncPositionOutputStream 
closing. (#5759)
2f2d4c90a0 is described below

commit 2f2d4c90a0d4c531ffe065898fe8341dcf1428cb
Author: zhoulii <zhouli....@foxmail.com>
AuthorDate: Tue Jun 17 17:38:24 2025 +0800

    [core] clear bufferQueue when AsyncPositionOutputStream closing. (#5759)
---
 .../src/main/java/org/apache/paimon/fs/AsyncPositionOutputStream.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/paimon-common/src/main/java/org/apache/paimon/fs/AsyncPositionOutputStream.java
 
b/paimon-common/src/main/java/org/apache/paimon/fs/AsyncPositionOutputStream.java
index 382fa44f6d..b41b759e35 100644
--- 
a/paimon-common/src/main/java/org/apache/paimon/fs/AsyncPositionOutputStream.java
+++ 
b/paimon-common/src/main/java/org/apache/paimon/fs/AsyncPositionOutputStream.java
@@ -211,6 +211,7 @@ public class AsyncPositionOutputStream extends 
PositionOutputStream {
         } catch (ExecutionException e) {
             throw new RuntimeException(e);
         }
+        this.bufferQueue.clear();
         this.closed = true;
     }