Skip to content

Commit 3b645dd

Browse files
committed
Expose attemptId in Stage.
1 parent c0474b1 commit 3b645dd

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

core/src/main/scala/org/apache/spark/scheduler/SparkListener.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -75,9 +75,11 @@ case class SparkListenerBlockManagerRemoved(blockManagerId: BlockManagerId)
7575
@DeveloperApi
7676
case class SparkListenerUnpersistRDD(rddId: Int) extends SparkListenerEvent
7777

78+
@DeveloperApi
7879
case class SparkListenerApplicationStart(appName: String, time: Long, sparkUser: String)
7980
extends SparkListenerEvent
8081

82+
@DeveloperApi
8183
case class SparkListenerApplicationEnd(time: Long) extends SparkListenerEvent
8284

8385
/** An event used in the listener to shutdown the listener daemon thread. */

core/src/main/scala/org/apache/spark/scheduler/Stage.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -106,6 +106,8 @@ private[spark] class Stage(
106106
id
107107
}
108108

109+
def attemptId: Int = nextAttemptId
110+
109111
val name = callSite.short
110112
val details = callSite.long
111113

0 commit comments

Comments
 (0)