Update CatalogMgr.java

zhangm365 · Sep 12, 2024 · 4386e83 · 4386e83
1 parent 22cdb61
commit 4386e83
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/CatalogMgr.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/CatalogMgr.java
@@ -238,8 +238,10 @@ private void readUnlock() {
      */
     public void createCatalog(CreateCatalogStmt stmt) throws UserException {
         if (nameToCatalog.containsKey(stmt.getCatalogName())) {
-            LOG.warn("Catalog {} is already exist.", stmt.getCatalogName());
-            throw new DdlException("Catalog had already exist with name: " + stmt.getCatalogName());
+            if (stmt.isSetIfNotExists()) {
+                LOG.warn("Catalog {} is already exist.", stmt.getCatalogName());
+                throw new DdlException("Catalog had already exist with name: " + stmt.getCatalogName());
+            }
         }
 
         long id = Env.getCurrentEnv().getNextId();