(fluss) branch main updated: [hotfix] Fix data lake catalog connection resource is not closed in flink catalog. (#2087)

[yuxia]

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

yuxia 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 e91106c24 [hotfix] Fix data lake catalog connection resource is not 
closed in flink catalog. (#2087)
e91106c24 is described below

commit e91106c249ef8dac20135e58dafb6f51ba912724
Author: Kerwin <37063904+zhuangch...@users.noreply.github.com>
AuthorDate: Mon Dec 15 13:44:45 2025 +0800

    [hotfix] Fix data lake catalog connection resource is not closed in flink 
catalog. (#2087)
---
 .../src/main/java/org/apache/fluss/metadata/TableChange.java     | 2 +-
 .../main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java   | 1 +
 .../main/java/org/apache/fluss/flink/lake/LakeFlinkCatalog.java  | 9 ++++++++-
 3 files changed, 10 insertions(+), 2 deletions(-)

diff --git 
a/fluss-common/src/main/java/org/apache/fluss/metadata/TableChange.java 
b/fluss-common/src/main/java/org/apache/fluss/metadata/TableChange.java
index e012a38f6..fcc8462d9 100644
--- a/fluss-common/src/main/java/org/apache/fluss/metadata/TableChange.java
+++ b/fluss-common/src/main/java/org/apache/fluss/metadata/TableChange.java
@@ -27,7 +27,7 @@ import java.util.Objects;
 public interface TableChange {
 
     /**
-     * A table change toadd the column with specified position.
+     * A table change to add the column with specified position.
      *
      * <p>It is equal to the following statement:
      *
diff --git 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java
 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java
index 0627e3f68..16dc60c86 100644
--- 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java
+++ 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java
@@ -158,6 +158,7 @@ public class FlinkCatalog extends AbstractCatalog {
     public void close() throws CatalogException {
         IOUtils.closeQuietly(admin, "fluss-admin");
         IOUtils.closeQuietly(connection, "fluss-connection");
+        IOUtils.closeQuietly(lakeFlinkCatalog, "fluss-lake-catalog");
     }
 
     @Override
diff --git 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeFlinkCatalog.java
 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeFlinkCatalog.java
index 3eb0db5d9..b51776419 100644
--- 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeFlinkCatalog.java
+++ 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeFlinkCatalog.java
@@ -36,7 +36,7 @@ import static org.apache.fluss.metadata.DataLakeFormat.PAIMON;
 import static org.apache.fluss.utils.Preconditions.checkNotNull;
 
 /** A lake flink catalog to delegate the operations on lake table. */
-public class LakeFlinkCatalog {
+public class LakeFlinkCatalog implements AutoCloseable {
 
     private final String catalogName;
     private final ClassLoader classLoader;
@@ -93,6 +93,13 @@ public class LakeFlinkCatalog {
         return lakeFormat;
     }
 
+    @Override
+    public void close() throws Exception {
+        if (catalog != null) {
+            catalog.close();
+        }
+    }
+
     /**
      * Factory for creating Paimon Catalog instances.
      *