diff --git a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/snapshot/defrag/SnapshotDefragService.java b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/snapshot/defrag/SnapshotDefragService.java index cd825a956624..54ee0a1f9a4b 100644 --- a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/snapshot/defrag/SnapshotDefragService.java +++ b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/snapshot/defrag/SnapshotDefragService.java @@ -613,10 +613,10 @@ private boolean checkAndDefragSnapshot(SnapshotChainManager chainManager, UUID s checkpointMetadataManager = null; // Switch the snapshot DB location to the new version. previousVersion = atomicSwitchSnapshotDB(snapshotId, checkpointLocation); + omSnapshotManager.deleteSnapshotCheckpointDirectories(snapshotId, previousVersion); } finally { snapshotContentLocks.releaseLock(); } - omSnapshotManager.deleteSnapshotCheckpointDirectories(snapshotId, previousVersion); } finally { if (checkpointMetadataManager != null) { checkpointMetadataManager.close();