This is an automated email from the ASF dual-hosted git repository.
siyao 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 c848b1601e HDDS-7598. Quota for snapshot handling (#4704)
c848b1601e is described below
commit c848b1601e5fdb09971150f1643818670f0de769
Author: Sumit Agrawal <[email protected]>
AuthorDate: Wed May 24 06:51:44 2023 +0530
HDDS-7598. Quota for snapshot handling (#4704)
---
.../om/response/key/OMDirectoriesPurgeResponseWithFSO.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/response/key/OMDirectoriesPurgeResponseWithFSO.java
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/response/key/OMDirectoriesPurgeResponseWithFSO.java
index 2314d93adf..a82ccc9d6e 100644
---
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/response/key/OMDirectoriesPurgeResponseWithFSO.java
+++
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/response/key/OMDirectoriesPurgeResponseWithFSO.java
@@ -85,6 +85,13 @@ public class OMDirectoriesPurgeResponseWithFSO extends
OmKeyResponse {
} else {
processPaths(metadataManager, batchOp);
}
+
+ // update bucket quota in active db
+ for (OmBucketInfo omBucketInfo : volBucketInfoMap.values()) {
+ metadataManager.getBucketTable().putWithBatch(batchOp,
+ metadataManager.getBucketKey(omBucketInfo.getVolumeName(),
+ omBucketInfo.getBucketName()), omBucketInfo);
+ }
}
public void processPaths(OMMetadataManager omMetadataManager,
@@ -151,13 +158,6 @@ public class OMDirectoriesPurgeResponseWithFSO extends
OmKeyResponse {
LOG.info("Purge Deleted Directory DBKey: {}", path.getDeletedDir());
}
}
-
- // update bucket usedBytes.
- for (OmBucketInfo omBucketInfo : volBucketInfoMap.values()) {
- omMetadataManager.getBucketTable().putWithBatch(batchOperation,
- omMetadataManager.getBucketKey(omBucketInfo.getVolumeName(),
- omBucketInfo.getBucketName()), omBucketInfo);
- }
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
