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"); } }