[spark] Fix HiveMigrator hive api version compatible issue (#3381)

apache · May 22, 2024 · 20c7a28 · 20c7a28
1 parent 2c38b03
commit 20c7a28
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/...n-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveMigrator.java b/...n-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/migrate/HiveMigrator.java
@@ -224,8 +224,13 @@ public void renameTable(boolean ignoreIfNotExists) throws Exception {
 
     private void checkPrimaryKey() throws Exception {
         PrimaryKeysRequest primaryKeysRequest = new PrimaryKeysRequest(sourceDatabase, sourceTable);
-        if (!client.getPrimaryKeys(primaryKeysRequest).isEmpty()) {
-            throw new IllegalArgumentException("Can't migrate primary key table yet.");
+        try {
+            if (!client.getPrimaryKeys(primaryKeysRequest).isEmpty()) {
+                throw new IllegalArgumentException("Can't migrate primary key table yet.");
+            }
+        } catch (Exception e) {
+            LOG.warn(
+                    "Your Hive version is low which not support get_primary_keys, skip primary key check firstly!");
         }
     }