diff --git a/src/main/java/org/apache/paimon/trino/TrinoMetadata.java b/src/main/java/org/apache/paimon/trino/TrinoMetadata.java index 8fac45c..7773999 100644 --- a/src/main/java/org/apache/paimon/trino/TrinoMetadata.java +++ b/src/main/java/org/apache/paimon/trino/TrinoMetadata.java @@ -305,7 +305,7 @@ public void createSchema( try { catalog.initSession(session); - catalog.createDatabase(schemaName, true); + catalog.createDatabase(schemaName, false); } catch (Catalog.DatabaseAlreadyExistException e) { throw new RuntimeException(format("database already existed: '%s'", schemaName)); }