Should fix issue teragrep#165

StrongestNumber9 · Jan 29, 2025 · 08af5b7 · 08af5b7
1 parent e233bda
commit 08af5b7
Showing 1 changed file with 1 addition and 3 deletions.
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
@@ -248,11 +248,9 @@ private String detectSparkScalaVersion(String sparkHome, Map<String, String> env
     LOGGER.info("Detect scala version from SPARK_HOME: {}", sparkHome);
     ProcessBuilder builder = new ProcessBuilder(sparkHome + "/bin/spark-submit", "--version");
     builder.environment().putAll(env);
-    File processOutputFile = File.createTempFile("zeppelin-spark", ".out");
-    builder.redirectError(processOutputFile);
     Process process = builder.start();
     process.waitFor();
-    String processOutput = IOUtils.toString(new FileInputStream(processOutputFile), StandardCharsets.UTF_8);
+    String processOutput = IOUtils.toString(process.getErrorStream(), StandardCharsets.UTF_8);
     Pattern pattern = Pattern.compile(".*Using Scala version (.*),.*");
     Matcher matcher = pattern.matcher(processOutput);
     if (matcher.find()) {