This is an automated email from the ASF dual-hosted git repository.
hemant 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 4d3d834c60 HDDS-12650. Added logs to SnapshotDeletingService to
indicate skipped snapshots. (#8123)
4d3d834c60 is described below
commit 4d3d834c607d2e38acdb2ffbd7f5310cd977aa5f
Author: SaketaChalamchala <[email protected]>
AuthorDate: Tue Mar 25 11:27:55 2025 -0700
HDDS-12650. Added logs to SnapshotDeletingService to indicate skipped
snapshots. (#8123)
---
.../apache/hadoop/ozone/om/service/SnapshotDeletingService.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/service/SnapshotDeletingService.java
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/service/SnapshotDeletingService.java
index 7fabe79a2a..8b28416f4e 100644
---
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/service/SnapshotDeletingService.java
+++
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/service/SnapshotDeletingService.java
@@ -165,6 +165,8 @@ public BackgroundTaskResult call() throws
InterruptedException {
while (iterator.hasNext() && snapshotLimit > 0 && remaining > 0) {
SnapshotInfo snapInfo = SnapshotUtils.getSnapshotInfo(ozoneManager,
chainManager, iterator.next());
if (shouldIgnoreSnapshot(snapInfo)) {
+ LOG.debug("Skipping Snapshot Deletion processing because " +
+ "the snapshot is active or DB changes are not flushed: {}",
snapInfo.getTableKey());
continue;
}
LOG.info("Started Snapshot Deletion Processing for snapshot : {}",
snapInfo.getTableKey());
@@ -173,13 +175,19 @@ public BackgroundTaskResult call() throws
InterruptedException {
// another.
if (nextSnapshot != null &&
nextSnapshot.getSnapshotStatus() !=
SnapshotInfo.SnapshotStatus.SNAPSHOT_ACTIVE) {
+ LOG.info("Skipping Snapshot Deletion processing for : {} because
the next snapshot is DELETED.",
+ snapInfo.getTableKey());
continue;
}
// nextSnapshot = null means entries would be moved to AOS.
if (nextSnapshot == null) {
+ LOG.info("Snapshot: {} entries will be moved to AOS.",
snapInfo.getTableKey());
waitForKeyDeletingService();
waitForDirDeletingService();
+ } else {
+ LOG.info("Snapshot: {} entries will be moved to next active
snapshot: {}",
+ snapInfo.getTableKey(), nextSnapshot.getTableKey());
}
try (ReferenceCounted<OmSnapshot> snapshot =
omSnapshotManager.getSnapshot(
snapInfo.getVolumeName(), snapInfo.getBucketName(),
snapInfo.getName())) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
