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 f8744be commit 8fe31e0Copy full SHA for 8fe31e0
core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -103,7 +103,7 @@ class DAGScheduler(
103
// may be retried. However, it only makes sense to limit the number of times that a stage fails
104
// if it's failing for the same reason every time. Therefore, track why a stage fails as well as
105
// how many times it has failed.
106
- case class StageFailure(failureReason : String) {
+ private[scheduler] case class StageFailure(failureReason : String) {
107
var count = 1
108
def fail() = { count += 1 }
109
def shouldAbort(): Boolean = { count >= maxStageFailures }
0 commit comments