You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by hv...@apache.org on 2023/03/07 15:13:25 UTC
[spark] branch master updated: [SPARK-42656][SPARK SHELL][CONNECT][FOLLOWUP] Add same `ClassNotFoundException` catch to `repl.Main` for Scala 2.13
This is an automated email from the ASF dual-hosted git repository.
hvanhovell pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 67328de6af5 [SPARK-42656][SPARK SHELL][CONNECT][FOLLOWUP] Add same `ClassNotFoundException` catch to `repl.Main` for Scala 2.13
67328de6af5 is described below
commit 67328de6af54aea22cd17574ff627b77718427b9
Author: yangjie01 <ya...@baidu.com>
AuthorDate: Tue Mar 7 11:13:06 2023 -0400
[SPARK-42656][SPARK SHELL][CONNECT][FOLLOWUP] Add same `ClassNotFoundException` catch to `repl.Main` for Scala 2.13
### What changes were proposed in this pull request?
This pr add the same `ClassNotFoundException` catch to `repl.Main` for Scala 2.13 as https://github.com/apache/spark/pull/40305 due `org/apache/spark/repl/Main.scala` is Scala version sensitive。
### Why are the changes needed?
Make sure Scala 2.12 and 2.13 have the same logic
### Does this PR introduce _any_ user-facing change?
No
### How was this patch tested?
Manual check
Closes #40318 from LuciferYang/SPARK-42656-FOLLOWUP.
Authored-by: yangjie01 <ya...@baidu.com>
Signed-off-by: Herman van Hovell <he...@databricks.com>
---
repl/src/main/scala-2.13/org/apache/spark/repl/Main.scala | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/repl/src/main/scala-2.13/org/apache/spark/repl/Main.scala b/repl/src/main/scala-2.13/org/apache/spark/repl/Main.scala
index 95115934ed1..c8d9be4253d 100644
--- a/repl/src/main/scala-2.13/org/apache/spark/repl/Main.scala
+++ b/repl/src/main/scala-2.13/org/apache/spark/repl/Main.scala
@@ -129,6 +129,11 @@ object Main extends Logging {
sparkContext = sparkSession.sparkContext
sparkSession
} catch {
+ case e: ClassNotFoundException if isShellSession && e.getMessage.contains(
+ "org.apache.spark.sql.connect.SparkConnectPlugin") =>
+ logError("Failed to load spark connect plugin.")
+ logError("You need to build Spark with -Pconnect.")
+ sys.exit(1)
case e: Exception if isShellSession =>
logError("Failed to initialize Spark session.", e)
sys.exit(1)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org