Close db before throwing version-related exception.

Marcelo Vanzin · Marcelo Vanzin · commit e22bceb5314c · 2018-01-02T15:22:26.000-08:00
diff --git a/common/kvstore/src/main/java/org/apache/spark/util/kvstore/LevelDB.java b/common/kvstore/src/main/java/org/apache/spark/util/kvstore/LevelDB.java
@@ -83,6 +83,7 @@ public LevelDB(File path, KVStoreSerializer serializer) throws Exception {
     if (versionData != null) {
       long version = serializer.deserializeLong(versionData);
       if (version != STORE_VERSION) {
+        close();
         throw new UnsupportedStoreVersionException();
       }
     } else {

Original file line number	Diff line number	Diff line change
`@@ -83,6 +83,7 @@ public LevelDB(File path, KVStoreSerializer serializer) throws Exception {`
`83`	`83`	`if (versionData != null) {`
`84`	`84`	`long version = serializer.deserializeLong(versionData);`
`85`	`85`	`if (version != STORE_VERSION) {`
	`86`	`+ close();`
`86`	`87`	`throw new UnsupportedStoreVersionException();`
`87`	`88`	`}`
`88`	`89`	`} else {`