Delete metadata that has been deleted in UFS when the client cancels.

Alluxio · Aug 16, 2023 · 4e15053 · 4e15053
1 parent 6dc8ed2
commit 4e15053
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/dora/core/server/master/src/main/java/alluxio/master/file/DefaultFileSystemMaster.java b/dora/core/server/master/src/main/java/alluxio/master/file/DefaultFileSystemMaster.java
@@ -2223,7 +2223,10 @@ public void deleteInternal(RpcContext rpcContext, LockedInodePath inodePath,
       // We go through each inode, removing it from its parent set and from mDelInodes. If it's a
       // file, we deal with the checkpoints and blocks as well.
       for (int i = inodesToDelete.size() - 1; i >= 0; i--) {
-        rpcContext.throwIfCancelled();
+        if (rpcContext.isCancelled()) {
+          inodesToDelete.set(i, null);
+          continue;
+        }
         Pair<AlluxioURI, LockedInodePath> inodePairToDelete = inodesToDelete.get(i);
         AlluxioURI alluxioUriToDelete = inodePairToDelete.getFirst();
         Inode inodeToDelete = inodePairToDelete.getSecond().getInode();