Close the leveldb on stop

apache · Aug 19, 2016 · 2643d56 · 2643d56
1 parent 8b4ba9d
commit 2643d56
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java b/common/network-yarn/src/main/java/org/apache/spark/network/yarn/YarnShuffleService.java
@@ -310,6 +310,9 @@ protected void serviceStop() {
       if (blockHandler != null) {
         blockHandler.close();
       }
+      if (db != null) {
+        db.close();
+      } 
     } catch (Exception e) {
       logger.error("Exception when stopping service", e);
     }