1

Author: Zouxxyy

paimon-common/src/main/java/org/apache/paimon/catalog/CatalogContext.java

@@ -88,11 +88,6 @@ public static CatalogContext create(Options options, FileIOLoader fallbackIOLoad
         return new CatalogContext(options, null, null, fallbackIOLoader, null);
     }
 
-    public static CatalogContext create(
-            Options options, FileIOLoader fallbackIOLoader, @Nullable String catalogName) {
-        return new CatalogContext(options, null, null, fallbackIOLoader, catalogName);
-    }
-
     public static CatalogContext create(
             Options options, FileIOLoader preferIOLoader, FileIOLoader fallbackIOLoader) {
         return new CatalogContext(options, null, preferIOLoader, fallbackIOLoader, null);

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalogFactory.java

@@ -55,6 +55,7 @@ public FlinkCatalog createCatalog(Context context) {
                 CatalogContext.create(
                         Options.fromMap(context.getOptions()),
                         new FlinkFileIOLoader(),
+                        null,
                         context.getName()),
                 context.getClassLoader());
     }

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkGenericCatalogFactory.java

@@ -93,7 +93,8 @@ public static FlinkGenericCatalog createCatalog(
         FlinkCatalog paimon =
                 new FlinkCatalog(
                         org.apache.paimon.catalog.CatalogFactory.createCatalog(
-                                CatalogContext.create(options, new FlinkFileIOLoader(), name), cl),
+                                CatalogContext.create(options, new FlinkFileIOLoader(), null, name),
+                                cl),
                         name,
                         options.get(DEFAULT_DATABASE),
                         options);