diff --git a/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/table/catalog/PulsarCatalog.java b/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/table/catalog/PulsarCatalog.java
index d1d58932604fd..23dee4b25c007 100644
--- a/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/table/catalog/PulsarCatalog.java
+++ b/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/table/catalog/PulsarCatalog.java
@@ -53,8 +53,6 @@
 import java.util.List;
 import java.util.Optional;
 
-import static org.apache.flink.connector.pulsar.table.catalog.PulsarCatalogFactoryOptions.DEFAULT_DATABASE;
-
 /**
  * Catalog implementation to use Pulsar to store metadatas for Flink tables/databases.
  *
@@ -123,7 +121,7 @@ public void open() throws CatalogException {
         CatalogDatabaseImpl defaultDatabase =
                 new CatalogDatabaseImpl(new HashMap<>(), "The default database for PulsarCatalog");
         try {
-            createDatabase(catalogConfiguration.get(DEFAULT_DATABASE), defaultDatabase, true);
+            createDatabase(getDefaultDatabase(), defaultDatabase, true);
         } catch (DatabaseAlreadyExistException e) {
             throw new CatalogException(
                     "Error: should ignore default database if not exist instead of throwing exception");