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 index 14b4d171835c..9be9db65358a 100644 --- 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 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