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 57d0ef4 commit e8aad6cCopy full SHA for e8aad6c
core/src/main/scala/org/apache/spark/serializer/SerializationDebugger.scala
@@ -23,6 +23,7 @@ import java.security.AccessController
23
24
import scala.annotation.tailrec
25
import scala.collection.mutable
26
+import scala.util.control.NonFatal
27
28
import org.apache.spark.Logging
29
@@ -39,9 +40,9 @@ private[serializer] object SerializationDebugger extends Logging {
39
40
new NotSerializableException(
41
e.getMessage + "\nSerialization stack:\n" + find(obj).map("\t- " + _).mkString("\n"))
42
} catch {
- case e2: Exception =>
43
+ case NonFatal(t) =>
44
// Fall back to old exception
- logWarning("Exception in serialization debugger", e2)
45
+ logWarning("Exception in serialization debugger", t)
46
e
47
}
48
} else {
0 commit comments