Skip to content

Commit 4261454

Browse files
committed
Add docs for new configs & code style
1 parent ce0868a commit 4261454

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,8 +50,11 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A
5050
val conf = scheduler.sc.conf
5151
private val timeout = AkkaUtils.askTimeout(conf)
5252
private val akkaFrameSize = AkkaUtils.maxFrameSizeBytes(conf)
53+
// Submit stage only after (registered executors / total executors) arrived the ratio.
5354
var minRegisteredRatio = conf.getDouble("spark.scheduler.minRegisteredExecutorsRatio", 0)
54-
val maxRegisteredWaitingTime = conf.getInt("spark.scheduler.maxRegisteredExecutorsWaitingTime", 30000)
55+
// Whatever minRegisteredExecutorsRatio is arrived, submit stage after the time(milliseconds).
56+
val maxRegisteredWaitingTime =
57+
conf.getInt("spark.scheduler.maxRegisteredExecutorsWaitingTime", 30000)
5558
val createTime = System.currentTimeMillis()
5659
var ready = if (minRegisteredRatio <= 0) true else false
5760

0 commit comments

Comments
 (0)