Fixes memory leak reported by Coverity

StrongestNumber9 · Feb 5, 2025 · 8cba732 · 8cba732
1 parent 902643c
commit 8cba732
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...gine/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java b/...gine/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java
@@ -20,6 +20,7 @@
 import java.io.FileInputStream;
 import java.io.FilenameFilter;
 import java.io.IOException;
+import java.io.InputStream;
 import java.net.URL;
 import java.net.URLClassLoader;
 import java.nio.charset.StandardCharsets;
@@ -250,7 +251,10 @@ private String detectSparkScalaVersion(String sparkHome, Map<String, String> env
     builder.environment().putAll(env);
     Process process = builder.start();
     process.waitFor();
-    String processOutput = IOUtils.toString(process.getErrorStream(), StandardCharsets.UTF_8);
+    String processOutput;
+    try(InputStream inputStream = process.getErrorStream()) {
+      processOutput = IOUtils.toString(inputStream, StandardCharsets.UTF_8);
+    }
     Pattern pattern = Pattern.compile(".*Using Scala version (.*),.*");
     Matcher matcher = pattern.matcher(processOutput);
     if (matcher.find()) {