Should fix issue teragrep#165 (teragrep#170)

StrongestNumber9 · Feb 4, 2025 · 902643c · 902643c
1 parent a32b62b
commit 902643c
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()) {