diff --git a/storage/src/main/java/org/apache/uniffle/storage/common/LocalStorage.java b/storage/src/main/java/org/apache/uniffle/storage/common/LocalStorage.java index 7561709736..f2c79ac1de 100644 --- a/storage/src/main/java/org/apache/uniffle/storage/common/LocalStorage.java +++ b/storage/src/main/java/org/apache/uniffle/storage/common/LocalStorage.java @@ -230,7 +230,7 @@ public void removeResources(String shuffleKey) { LOG.info("Start to remove resource of {}", shuffleKey); try { metaData.updateDiskSize(-metaData.getShuffleSize(shuffleKey)); - metaData.remoteShuffle(shuffleKey); + metaData.removeShuffle(shuffleKey); LOG.info( "Finish remove resource of {}, disk size is {} and {} shuffle metadata", shuffleKey, diff --git a/storage/src/main/java/org/apache/uniffle/storage/common/LocalStorageMeta.java b/storage/src/main/java/org/apache/uniffle/storage/common/LocalStorageMeta.java index 056ca4f6b7..0cb80d4c1d 100644 --- a/storage/src/main/java/org/apache/uniffle/storage/common/LocalStorageMeta.java +++ b/storage/src/main/java/org/apache/uniffle/storage/common/LocalStorageMeta.java @@ -71,7 +71,7 @@ public void prepareStartRead(String shuffleId) { } } - public void remoteShuffle(String shuffleKey) { + public void removeShuffle(String shuffleKey) { shuffleMetaMap.remove(shuffleKey); }