[improve] allow migrate to existing database

apache · Dec 13, 2024 · 6f2fef8 · 6f2fef8
1 parent 98a4ec3
commit 6f2fef8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/paimon-core/src/main/java/org/apache/paimon/iceberg/migrate/IcebergMigrator.java b/paimon-core/src/main/java/org/apache/paimon/iceberg/migrate/IcebergMigrator.java
@@ -142,7 +142,7 @@ public void executeMigrate() throws Exception {
         Schema paimonSchema = icebergSchemaToPaimonSchema(icebergMetadata);
         Identifier paimonIdentifier = Identifier.create(paimonDatabaseName, paimonTableName);
 
-        paimonCatalog.createDatabase(paimonDatabaseName, false);
+        paimonCatalog.createDatabase(paimonDatabaseName, true);
         paimonCatalog.createTable(paimonIdentifier, paimonSchema, false);
 
         try {