Details
-
Bug
-
Status: Patch Available
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
CopyCommiter#deleteMissing(Configuration conf) does the following in a loop for all files that need to be deleted:
if (result) { LOG.info("Deleted " + trgtFileStatus.getPath() + " - Missing at source"); deletedEntries++; } else { throw new IOException("Unable to delete " + trgtFileStatus.getPath()); }
If for some reason there is a failure to delete a file, then an exception is thrown and no other files will be deleted.
It seems more reasonable to issue a warning here instead of throw an exception.