From 3c8f6617202a86f238f762229740fe1660101cbc Mon Sep 17 00:00:00 2001 From: miinhho Date: Sat, 25 Jul 2026 22:39:31 +0900 Subject: [PATCH] [ZEPPELIN-6548] Use specific exceptions for Spark Scala detection fallback --- .../interpreter/launcher/SparkInterpreterLauncher.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/zeppelin-server/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java b/zeppelin-server/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java index 98e0e5e0b82..b2b01685eea 100644 --- a/zeppelin-server/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java +++ b/zeppelin-server/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java @@ -318,10 +318,10 @@ private String detectSparkScalaVersionByReplClass(String sparkHome) throws Excep } if (sparkReplJars.isEmpty()) { - throw new Exception("No spark-repl jar found in SPARK_HOME: " + sparkHome); + throw new IOException("No spark-repl jar found in SPARK_HOME: " + sparkHome); } if (sparkReplJars.size() > 1) { - throw new Exception("Multiple spark-repl jar found in SPARK_HOME: " + sparkHome); + throw new IOException("Multiple spark-repl jar found in SPARK_HOME: " + sparkHome); } String fileName = sparkReplJars.get(0).getFileName().toString(); @@ -330,7 +330,7 @@ private String detectSparkScalaVersionByReplClass(String sparkHome) throws Excep } else if (fileName.contains("spark-repl_2.13")) { return "2.13"; } else { - throw new Exception("Can not detect the scala version by spark-repl"); + throw new IllegalArgumentException("Can not detect the scala version by spark-repl"); } }