Fix Stage.name return "apply at Option.scala:120"

yinxusen · Mar 25, 2014 · 1bc22d7 · 1bc22d7
1 parent dc126f2
commit 1bc22d7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/util/Utils.scala b/core/src/main/scala/org/apache/spark/util/Utils.scala
@@ -697,7 +697,7 @@ private[spark] object Utils extends Logging {
     var finished = false
     var firstUserClass = "<unknown>"
 
-    for (el <- trace) {
+    for (el <- trace if el.getClassName != "scala.Option") {
       if (!finished) {
         if (SPARK_CLASS_REGEX.findFirstIn(el.getClassName).isDefined) {
           lastSparkMethod = if (el.getMethodName == "<init>") {