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 f99ee470ac [hotfix] Log channelWriterOutputView writeBytes after close 
(#7101)
f99ee470ac is described below

commit f99ee470ac7ac4ffb77f89fdb0f93b83cb6fc2a2
Author: Zouxxyy <[email protected]>
AuthorDate: Thu Jan 22 12:46:45 2026 +0800

    [hotfix] Log channelWriterOutputView writeBytes after close (#7101)
---
 paimon-core/src/main/java/org/apache/paimon/disk/ExternalBuffer.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/disk/ExternalBuffer.java 
b/paimon-core/src/main/java/org/apache/paimon/disk/ExternalBuffer.java
index 60cb36bd2f..74c0899bfc 100644
--- a/paimon-core/src/main/java/org/apache/paimon/disk/ExternalBuffer.java
+++ b/paimon-core/src/main/java/org/apache/paimon/disk/ExternalBuffer.java
@@ -162,11 +162,11 @@ public class ExternalBuffer implements RowBuffer {
                                 : segment.size();
                 channelWriterOutputView.write(segment, 0, bufferSize);
             }
+            channelWriterOutputView.close();
             LOG.info(
                     "here spill the reset buffer data with {} records {} 
bytes",
                     inMemoryBuffer.size(),
                     channelWriterOutputView.getWriteBytes());
-            channelWriterOutputView.close();
         } catch (IOException e) {
             channelWriterOutputView.closeAndDelete();
             throw e;

Reply via email to