Fix exception handling for Hive OPTIMIZE table procedure

trinodb · Dec 2, 2021 · 93b309e · 93b309e
1 parent 1727ae4
commit 93b309e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/HiveMetadata.java b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/HiveMetadata.java
@@ -2138,6 +2138,7 @@ private void finishOptimize(ConnectorSession session, ConnectorTableExecuteHandl
                     firstScannedPath = Optional.of(scannedPath);
                 }
                 retry().run("delete " + scannedPath, () -> fs.delete(scannedPath, false));
+                someDeleted = true;
                 remainingFilesToDelete.remove(scannedPath);
             }
         }