[AMORO-2440] Fix the batch deletion of Change Store files for Mixed F…

…ormat Table (#2439) fix remove change files
apache · Dec 18, 2023 · f66a4b5 · f66a4b5
1 parent 2c95b7b
commit f66a4b5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...r/src/main/java/com/netease/arctic/server/optimizing/maintainer/MixedTableMaintainer.java b/...r/src/main/java/com/netease/arctic/server/optimizing/maintainer/MixedTableMaintainer.java
@@ -452,7 +452,7 @@ private void tryClearChangeFiles(List<DataFile> changeFiles) {
           LOG.info("{} delete {} change files", unkeyedTable.name(), tableFiles.size());
           if (!tableFiles.isEmpty()) {
             DeleteFiles changeDelete = unkeyedTable.newDelete();
-            changeFiles.forEach(changeDelete::deleteFile);
+            tableFiles.forEach(changeDelete::deleteFile);
             changeDelete.commit();
           }
           LOG.info(