diff --git a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OMDBCheckpointServlet.java b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OMDBCheckpointServlet.java index 023f2cb3e1e..c234903bcde 100644 --- a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OMDBCheckpointServlet.java +++ b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OMDBCheckpointServlet.java @@ -182,6 +182,8 @@ private Set waitForSnapshotDirs(DBCheckpoint checkpoint) waitForDirToExist(path); snapshotPaths.add(path); } + } finally { + checkpointMetadataManager.stop(); } return snapshotPaths; } diff --git a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OmMetadataManagerImpl.java b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OmMetadataManagerImpl.java index 7e7dbc27772..2fea3c83128 100644 --- a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OmMetadataManagerImpl.java +++ b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OmMetadataManagerImpl.java @@ -709,7 +709,7 @@ protected void initializeOmTables(boolean addCacheMetrics) * Stop metadata manager. */ @Override - public void stop() throws Exception { + public void stop() throws IOException { if (store != null) { store.close(); store = null;