(paimon) branch master updated: [flink] Log info when creating Flink catalog (#6067)

[yunfengzhou]

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

yunfengzhou 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 8d54c2bbf3 [flink] Log info when creating Flink catalog (#6067)
8d54c2bbf3 is described below

commit 8d54c2bbf32740c3dc875a6c8352c1351ee00a1d
Author: Xuannan <suxuanna...@gmail.com>
AuthorDate: Thu Aug 14 09:28:16 2025 +0800

    [flink] Log info when creating Flink catalog (#6067)
---
 .../src/main/java/org/apache/paimon/flink/FlinkCatalog.java             | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java
index f4a1142031..d9205c814f 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java
@@ -33,6 +33,7 @@ import org.apache.paimon.function.FunctionChange;
 import org.apache.paimon.function.FunctionDefinition;
 import org.apache.paimon.function.FunctionImpl;
 import org.apache.paimon.manifest.PartitionEntry;
+import org.apache.paimon.options.CatalogOptions;
 import org.apache.paimon.options.Options;
 import org.apache.paimon.schema.NestedSchemaUtils;
 import org.apache.paimon.schema.Schema;
@@ -195,6 +196,7 @@ public class FlinkCatalog extends AbstractCatalog {
             ClassLoader classLoader,
             Options options) {
         super(name, defaultDatabase);
+        LOG.info("Creating Flink catalog: metastore={}", 
options.get(CatalogOptions.METASTORE));
         this.catalog = catalog;
         this.name = name;
         this.classLoader = classLoader;