diff --git a/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingQueue.java b/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingQueue.java index 2dcfcaca86..fb844a41a5 100644 --- a/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingQueue.java +++ b/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingQueue.java @@ -666,12 +666,13 @@ private void cancelTasks() { } private void loadTaskRuntimes(OptimizingProcess optimizingProcess) { - List> taskRuntimes = - getAs( - OptimizingMapper.class, - mapper -> - mapper.selectTaskRuntimes(tableRuntime.getTableIdentifier().getId(), processId)); try { + List> taskRuntimes = + getAs( + OptimizingMapper.class, + mapper -> + mapper.selectTaskRuntimes( + tableRuntime.getTableIdentifier().getId(), processId)); Map inputs = TaskFilesPersistence.loadTaskInputs(processId); taskRuntimes.forEach( taskRuntime -> { diff --git a/amoro-common/src/main/java/org/apache/amoro/CommonUnifiedCatalog.java b/amoro-common/src/main/java/org/apache/amoro/CommonUnifiedCatalog.java index 79b6e55be8..b49d860fbb 100644 --- a/amoro-common/src/main/java/org/apache/amoro/CommonUnifiedCatalog.java +++ b/amoro-common/src/main/java/org/apache/amoro/CommonUnifiedCatalog.java @@ -122,10 +122,6 @@ public void dropDatabase(String database) { @Override public AmoroTable loadTable(String database, String table) { - if (!databaseExists(database)) { - throw new NoSuchDatabaseException("Database: " + database + " does not exist."); - } - return formatCatalogAsOrder( TableFormat.MIXED_HIVE, TableFormat.MIXED_ICEBERG,