(fluss) branch main updated: [lake/iceberg] Fix listener leak in IcebergLakeCommitter (#3542)

[yuxia]

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

luoyuxia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new e426f401c [lake/iceberg] Fix listener leak in IcebergLakeCommitter 
(#3542)
e426f401c is described below

commit e426f401c9ced2724d7da36b6486264b2eb8a363
Author: GuoYu <511955...@qq.com>
AuthorDate: Tue Jun 30 15:54:55 2026 +0800

    [lake/iceberg] Fix listener leak in IcebergLakeCommitter (#3542)
---
 .../org/apache/fluss/lake/iceberg/tiering/IcebergLakeCommitter.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/fluss-lake/fluss-lake-iceberg/src/main/java/org/apache/fluss/lake/iceberg/tiering/IcebergLakeCommitter.java
 
b/fluss-lake/fluss-lake-iceberg/src/main/java/org/apache/fluss/lake/iceberg/tiering/IcebergLakeCommitter.java
index 06b572760..11744f1c8 100644
--- 
a/fluss-lake/fluss-lake-iceberg/src/main/java/org/apache/fluss/lake/iceberg/tiering/IcebergLakeCommitter.java
+++ 
b/fluss-lake/fluss-lake-iceberg/src/main/java/org/apache/fluss/lake/iceberg/tiering/IcebergLakeCommitter.java
@@ -63,12 +63,14 @@ public class IcebergLakeCommitter implements 
LakeCommitter<IcebergWriteResult, I
     private final Table icebergTable;
     private static final ThreadLocal<Long> currentCommitSnapshotId = new 
ThreadLocal<>();
 
+    static {
+        Listeners.register(new IcebergSnapshotCreateListener(), 
CreateSnapshotEvent.class);
+    }
+
     public IcebergLakeCommitter(IcebergCatalogProvider icebergCatalogProvider, 
TablePath tablePath)
             throws IOException {
         this.icebergCatalog = icebergCatalogProvider.get();
         this.icebergTable = getTable(tablePath);
-        // register iceberg listener
-        Listeners.register(new IcebergSnapshotCreateListener(), 
CreateSnapshotEvent.class);
     }
 
     @Override