[Enhancement] Catch more exceptions when executing dynamic partition

Signed-off-by: PengFei Li <[email protected]>
StarRocks · Sep 29, 2024 · a4f3229 · a4f3229
1 parent dcd238e
commit a4f3229
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/fe/fe-core/src/main/java/com/starrocks/clone/DynamicPartitionScheduler.java b/fe/fe-core/src/main/java/com/starrocks/clone/DynamicPartitionScheduler.java
@@ -435,7 +435,7 @@ public boolean executeDynamicPartitionForTable(Long dbId, Long tableId) {
                 }
                 dropPartitionClauses = getDropPartitionClause(db, olapTable, partitionColumn, partitionFormat);
                 tableName = olapTable.getName();
-            } catch (Exception e) {
+            } catch (Throwable e) {
                 LOG.warn("create or drop partition failed", e);
                 recordCreatePartitionFailedMsg(db.getOriginName(), olapTable.getName(), e.getMessage());
                 return false;
@@ -458,7 +458,7 @@ public boolean executeDynamicPartitionForTable(Long dbId, Long tableId) {
 
                 GlobalStateMgr.getCurrentState().getLocalMetastore().dropPartition(db, olapTable, dropPartitionClause);
                 clearDropPartitionFailedMsg(tableName);
-            } catch (DdlException e) {
+            } catch (Throwable e) {
                 recordDropPartitionFailedMsg(db.getOriginName(), tableName, e.getMessage());
             } finally {
                 locker.unLockDatabase(db.getId(), LockType.WRITE);
@@ -474,7 +474,7 @@ public boolean executeDynamicPartitionForTable(Long dbId, Long tableId) {
                     GlobalStateMgr.getCurrentState().getLocalMetastore().addPartitions(ctx,
                                 db, tableName, addPartitionClause);
                     clearCreatePartitionFailedMsg(tableName);
-                } catch (DdlException e) {
+                } catch (Throwable e) {
                     recordCreatePartitionFailedMsg(db.getOriginName(), tableName, e.getMessage());
                 }
             }