diff --git a/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala b/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala index ac2581c4e041e..f3d02b9b4abb6 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala @@ -268,14 +268,13 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A override def isReady(): Boolean = { if (sufficientResourcesRegistered) { - logInfo("SchedulerBackend is ready for scheduling beginning" + - ", total expected resources: " + totalExpectedResources.get() + - ", minRegisteredResourcesRatio: " + minRegisteredRatio) + logInfo("SchedulerBackend is ready for scheduling beginning, total expected resources: " + + s"$totalExpectedResources, minRegisteredResourcesRatio: $minRegisteredRatio") return true } if ((System.currentTimeMillis() - createTime) >= maxRegisteredWaitingTime) { logInfo("SchedulerBackend is ready for scheduling beginning after waiting " + - "maxRegisteredResourcesWaitingTime(ms): " + maxRegisteredWaitingTime) + s"maxRegisteredResourcesWaitingTime: $maxRegisteredWaitingTime(ms)") return true } false