[core] add check for make directory for db location when creating dat…

…abase (#4399)
apache · Oct 29, 2024 · 2348b5b · 2348b5b
1 parent 69390bd
commit 2348b5b
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/paimon-core/src/main/java/org/apache/paimon/catalog/FileSystemCatalog.java b/paimon-core/src/main/java/org/apache/paimon/catalog/FileSystemCatalog.java
@@ -70,7 +70,14 @@ protected void createDatabaseImpl(String name, Map<String, String> properties) {
                     "Currently filesystem catalog can't store database properties, discard properties: {}",
                     properties);
         }
-        uncheck(() -> fileIO.mkdirs(newDatabasePath(name)));
+
+        Path databasePath = newDatabasePath(name);
+        if (!uncheck(() -> fileIO.mkdirs(databasePath))) {
+            throw new RuntimeException(
+                    String.format(
+                            "Create database location failed, " + "database: %s, location: %s",
+                            name, databasePath));
+        }
     }
 
     @Override