Fix checkstyle.

aswinshakil · Sep 28, 2023 · d647921 · d647921
1 parent da3f654
commit d647921
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/...ne-manager/src/main/java/org/apache/hadoop/ozone/om/service/DirectoryDeletingService.java b/...ne-manager/src/main/java/org/apache/hadoop/ozone/om/service/DirectoryDeletingService.java
@@ -329,7 +329,8 @@ private void expandSnapshotDirectories(long remainNum) throws IOException {
                 if (isBufferLimitCrossed(ratisByteLimit, consumedSize,
                     request.getSerializedSize())) {
                   if (purgePathRequestList.size() != 0) {
-                    // if message buffer reaches max limit, avoid sending further
+                    // if message buffer reaches max limit,
+                    // avoid sending further
                     remainNum = 0;
                     break;
                   }

diff --git a/...one-manager/src/main/java/org/apache/hadoop/ozone/om/service/SnapshotDeletingService.java b/...one-manager/src/main/java/org/apache/hadoop/ozone/om/service/SnapshotDeletingService.java
@@ -402,7 +402,7 @@ private long handleDirectoryCleanUp(
         long startTime = Time.monotonicNow();
         deletedDirIterator.seek(dbBucketKeyForDir);
 
-        while (deletedDirIterator.hasNext()) {
+        while (remainNum > 0 && deletedDirIterator.hasNext()) {
           Table.KeyValue<String, OmKeyInfo> deletedDir =
               deletedDirIterator.next();
           String deletedDirKey = deletedDir.getKey();