This is an automated email from the ASF dual-hosted git repository.
swamirishi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 576d5cfa97e HDDS-13907. Prune ACLs from OmKeyInfo before building
purge requests in DirectoryDeletingService (#9275)
576d5cfa97e is described below
commit 576d5cfa97e0cb7ed0b904bd3dec4bd6d8a583cd
Author: Aryan Gupta <[email protected]>
AuthorDate: Wed Nov 12 01:55:04 2025 +0530
HDDS-13907. Prune ACLs from OmKeyInfo before building purge requests in
DirectoryDeletingService (#9275)
---
.../org/apache/hadoop/ozone/om/service/DirectoryDeletingService.java | 3 +++
1 file changed, 3 insertions(+)
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 001e686455f..39978e8f6e2 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<PurgePathRequest> prepareDeleteDirRequest(
keyManager.getPendingDeletionSubDirs(volumeBucketId.getVolumeId(),
volumeBucketId.getBucketId(),
pendingDeletedDirInfo, keyInfo -> true, remainingBufLimit);
List<OmKeyInfo> subDirs = subDirDeleteResult.getKeysToDelete();
+ subDirs.forEach(omKeyInfo -> omKeyInfo.setAcls(Collections.emptyList()));
remainingBufLimit -= subDirDeleteResult.getConsumedSize();
OMMetadataManager omMetadataManager = keyManager.getMetadataManager();
@@ -412,6 +414,7 @@ private Optional<PurgePathRequest> prepareDeleteDirRequest(
keyManager.getPendingDeletionSubFiles(volumeBucketId.getVolumeId(),
volumeBucketId.getBucketId(),
pendingDeletedDirInfo, keyInfo -> purgeDir ||
reclaimableFileFilter.apply(keyInfo), remainingBufLimit);
List<OmKeyInfo> subFiles = subFileDeleteResult.getKeysToDelete();
+ subFiles.forEach(omKeyInfo -> omKeyInfo.setAcls(Collections.emptyList()));
if (LOG.isDebugEnabled()) {
for (OmKeyInfo fileInfo : subFiles) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
