Skip to content

Commit 6386fda

Browse files
committed
fix
1 parent daaca52 commit 6386fda

File tree

3 files changed

+191
-225
lines changed

3 files changed

+191
-225
lines changed

paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveMigrator.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -135,10 +135,6 @@ public void deleteOriginTable(boolean deleteOriginTable) {
135135

136136
@Override
137137
public void executeMigrate() throws Exception {
138-
if (!client.tableExists(sourceDatabase, sourceTable)) {
139-
throw new RuntimeException("Source hive table does not exist");
140-
}
141-
142138
Table sourceHiveTable = client.getTable(sourceDatabase, sourceTable);
143139
Map<String, String> properties = new HashMap<>(sourceHiveTable.getParameters());
144140
checkPrimaryKey();

paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/MigrateFileProcedureTest.scala

Lines changed: 0 additions & 221 deletions
This file was deleted.

0 commit comments

Comments
 (0)