diff --git a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/service/DirectoryDeletingService.java b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/service/DirectoryDeletingService.java index 001e686455f1..39978e8f6e2f 100644 --- a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/service/DirectoryDeletingService.java +++ b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/service/DirectoryDeletingService.java @@ -29,6 +29,7 @@ import java.io.IOException; import java.util.ArrayList; import java.util.Collection; +import java.util.Collections; import java.util.HashMap; import java.util.Iterator; import java.util.List; @@ -394,6 +395,7 @@ private Optional prepareDeleteDirRequest( keyManager.getPendingDeletionSubDirs(volumeBucketId.getVolumeId(), volumeBucketId.getBucketId(), pendingDeletedDirInfo, keyInfo -> true, remainingBufLimit); List subDirs = subDirDeleteResult.getKeysToDelete(); + subDirs.forEach(omKeyInfo -> omKeyInfo.setAcls(Collections.emptyList())); remainingBufLimit -= subDirDeleteResult.getConsumedSize(); OMMetadataManager omMetadataManager = keyManager.getMetadataManager(); @@ -412,6 +414,7 @@ private Optional prepareDeleteDirRequest( keyManager.getPendingDeletionSubFiles(volumeBucketId.getVolumeId(), volumeBucketId.getBucketId(), pendingDeletedDirInfo, keyInfo -> purgeDir || reclaimableFileFilter.apply(keyInfo), remainingBufLimit); List subFiles = subFileDeleteResult.getKeysToDelete(); + subFiles.forEach(omKeyInfo -> omKeyInfo.setAcls(Collections.emptyList())); if (LOG.isDebugEnabled()) { for (OmKeyInfo fileInfo : subFiles) {