We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 28a9409 commit 7dfe41eCopy full SHA for 7dfe41e
1 file changed
core/src/main/scala/org/apache/spark/scheduler/Stage.scala
@@ -70,8 +70,10 @@ private[spark] class Stage(
70
var resultOfJob: Option[ActiveJob] = None
71
var pendingTasks = new HashSet[Task[_]]
72
73
- /** This is used to track the life cycle of broadcast,
74
- * then it can be release by GC once the stage is released */
+ /**
+ * This is used to track the life cycle of broadcast,
75
+ * then it can be release by GC once the stage is released
76
+ */
77
var broadcastedTaskBinary: Broadcast[Array[Byte]] = _
78
79
private var nextAttemptId = 0
0 commit comments