Skip to content

Commit a63b68f

Browse files
committed
Minor style and comment fixes
1 parent bdda06d commit a63b68f

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

core/src/main/scala/org/apache/spark/deploy/client/StandaloneAppClient.scala

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,6 @@ import org.apache.spark.util.{RpcUtils, ThreadUtils}
3939
* Takes a master URL, an app description, and a listener for cluster events, and calls
4040
* back the listener when various events occur.
4141
*
42-
*
4342
* @param masterUrls Each url should look like spark://host:port.
4443
*/
4544
private[spark] class StandaloneAppClient(

core/src/main/scala/org/apache/spark/deploy/master/Master.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -248,7 +248,7 @@ private[deploy] class Master(
248248
if (state == RecoveryState.STANDBY) {
249249
workerRef.send(MasterInStandby)
250250
} else {
251-
// If a worker attempts to decommission that isn't registered ignore it.
251+
// We use foreach since if it isn't registered we just skip it.
252252
idToWorker.get(id).foreach(decommissionWorker)
253253
}
254254

0 commit comments

Comments
 (0)