nsivabalan commented on a change in pull request #2421: URL: https://github.com/apache/hudi/pull/2421#discussion_r554469816
########## File path: hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/rollback/ListingBasedRollbackHelper.java ########## @@ -116,14 +116,31 @@ public ListingBasedRollbackHelper(HoodieTableMetaClient metaClient, HoodieWriteC .withDeletedFileResults(filesToDeletedStatus).build()); } case APPEND_ROLLBACK_BLOCK: { + // collect all log files that is supposed to be deleted with this rollback + String baseCommit = rollbackRequest.getLatestBaseInstant().get(); Review comment: Existing FSUtils.getAllLogFiles() expects fileId to be passed in. Hence have created a new method in FSUtils which lists all files disregarding fileId, but later filters for basecommit passed in. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org