Skip to content

Commit a9d8998

Browse files
author
Michael Gummelt
committed
remove extra comments
1 parent 973dce2 commit a9d8998

File tree

1 file changed

+0
-6
lines changed

1 file changed

+0
-6
lines changed

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

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -510,7 +510,6 @@ class CoarseGrainedSchedulerBackend(
510510

511511
/**
512512
* Request an additional number of executors from the cluster manager.
513-
*
514513
* @return whether the request is acknowledged.
515514
*/
516515
final override def requestExecutors(numAdditionalExecutors: Int): Boolean = {
@@ -545,7 +544,6 @@ class CoarseGrainedSchedulerBackend(
545544
/**
546545
* Update the cluster manager on our scheduling needs. Three bits of information are included
547546
* to help it make decisions.
548-
*
549547
* @param numExecutors The total number of executors we'd like to have. The cluster manager
550548
* shouldn't kill any running executor to reach this number, but,
551549
* if all existing executors were to die, this is the number of executors
@@ -591,7 +589,6 @@ class CoarseGrainedSchedulerBackend(
591589
* of requesting a delta of executors risks double counting new executors when there are
592590
* insufficient resources to satisfy the first request. We make the assumption here that the
593591
* cluster manager will eventually fulfill all requests when resources free up.
594-
*
595592
* @return a future whose evaluation indicates whether the request is acknowledged.
596593
*/
597594
protected def doRequestTotalExecutors(requestedTotal: Int): Future[Boolean] =
@@ -603,7 +600,6 @@ class CoarseGrainedSchedulerBackend(
603600
* When asking the executor to be replaced, the executor loss is considered a failure, and
604601
* killed tasks that are running on the executor will count towards the failure limits. If no
605602
* replacement is being requested, then the tasks will not count towards the limit.
606-
*
607603
* @param executorIds identifiers of executors to kill
608604
* @param replace whether to replace the killed executors with new ones, default false
609605
* @param force whether to force kill busy executors, default false
@@ -670,15 +666,13 @@ class CoarseGrainedSchedulerBackend(
670666

671667
/**
672668
* Kill the given list of executors through the cluster manager.
673-
*
674669
* @return whether the kill request is acknowledged.
675670
*/
676671
protected def doKillExecutors(executorIds: Seq[String]): Future[Boolean] =
677672
Future.successful(false)
678673

679674
/**
680675
* Request that the cluster manager kill all executors on a given host.
681-
*
682676
* @return whether the kill request is acknowledged.
683677
*/
684678
final override def killExecutorsOnHost(host: String): Boolean = {

0 commit comments

Comments
 (0)