Skip to content

Commit

Permalink
[AMORO-2440] Fix the batch deletion of Change Store files for Mixed F…
Browse files Browse the repository at this point in the history
…ormat Table (apache#2439)

fix remove change files
  • Loading branch information
wangtaohz authored and ShawHee committed Dec 29, 2023
1 parent 730a760 commit cede18a
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down

0 comments on commit cede18a

Please sign in to comment.