We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9193a0c commit a5a7d7fCopy full SHA for a5a7d7f
core/src/main/scala/org/apache/spark/SparkEnv.scala
@@ -107,8 +107,10 @@ class SparkEnv (
107
outputCommitCoordinator.stop()
108
rpcEnv.shutdown()
109
} catch {
110
- case NonFatal(e) =>
+ case e: ServerStateException =>
111
logInfo("Exception while SparkEnv stop", e)
112
+ case NonFatal(e) =>
113
+ throw e;
114
}
115
116
// Unfortunately Akka's awaitTermination doesn't actually wait for the Netty server to shut
0 commit comments