Skip to content

Commit 1bc22d7

Browse files
witgoaarondav
authored andcommitted
Fix Stage.name return "apply at Option.scala:120"
1 parent dc126f2 commit 1bc22d7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/util/Utils.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -697,7 +697,7 @@ private[spark] object Utils extends Logging {
697697
var finished = false
698698
var firstUserClass = "<unknown>"
699699

700-
for (el <- trace) {
700+
for (el <- trace if el.getClassName != "scala.Option") {
701701
if (!finished) {
702702
if (SPARK_CLASS_REGEX.findFirstIn(el.getClassName).isDefined) {
703703
lastSparkMethod = if (el.getMethodName == "<init>") {

0 commit comments

Comments
 (0)