From c82d241417078b8b0eddfa68641cb84c95d48ad7 Mon Sep 17 00:00:00 2001 From: Christophe Bornet Date: Thu, 23 Mar 2023 19:42:11 +0100 Subject: [PATCH 1/2] Fix catalog default-database creation --- .../flink/connector/pulsar/table/catalog/PulsarCatalog.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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..e01716f4907ba 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 @@ -123,7 +123,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"); From a708cba1124ed6c0c9942b128dc0eebb47396ec7 Mon Sep 17 00:00:00 2001 From: Christophe Bornet Date: Mon, 17 Apr 2023 01:20:03 +0200 Subject: [PATCH 2/2] Fix format --- .../flink/connector/pulsar/table/catalog/PulsarCatalog.java | 2 -- 1 file changed, 2 deletions(-) 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 e01716f4907ba..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. *