diff --git a/zeppelin-server/src/main/java/org/apache/zeppelin/interpreter/InterpreterSettingManager.java b/zeppelin-server/src/main/java/org/apache/zeppelin/interpreter/InterpreterSettingManager.java index e2959382206..f6086f4d06c 100644 --- a/zeppelin-server/src/main/java/org/apache/zeppelin/interpreter/InterpreterSettingManager.java +++ b/zeppelin-server/src/main/java/org/apache/zeppelin/interpreter/InterpreterSettingManager.java @@ -486,9 +486,10 @@ private boolean registerInterpreterFromResource(ClassLoader cl, String interpret } LOGGER.debug("Reading interpreter-setting.json from {} as Resource", url); - List registeredInterpreterList = - getInterpreterListFromJson(url.openStream()); - registerInterpreterSetting(registeredInterpreterList, interpreterDir, override); + try (InputStream stream = url.openStream()) { + List registeredInterpreterList = getInterpreterListFromJson(stream); + registerInterpreterSetting(registeredInterpreterList, interpreterDir, override); + } return true; } @@ -498,9 +499,10 @@ private boolean registerInterpreterFromPath(String interpreterDir, String interp Path interpreterJsonPath = Paths.get(interpreterDir, interpreterJson); if (Files.exists(interpreterJsonPath)) { LOGGER.debug("Reading interpreter-setting.json from file {}", interpreterJsonPath); - List registeredInterpreterList = - getInterpreterListFromJson(new FileInputStream(interpreterJsonPath.toFile())); - registerInterpreterSetting(registeredInterpreterList, interpreterDir, override); + try (InputStream stream = new FileInputStream(interpreterJsonPath.toFile())) { + List registeredInterpreterList = getInterpreterListFromJson(stream); + registerInterpreterSetting(registeredInterpreterList, interpreterDir, override); + } return true; } return false;