Small coment & visibility cleanup

Author: holdenk

core/src/main/scala/org/apache/spark/ExecutorAllocationClient.scala

@@ -103,7 +103,7 @@ private[spark] trait ExecutorAllocationClient {
 
   /**
    * Request that the cluster manager decommission the specified executor.
-   * Default implementation delegates to kill, scheduler can override
+   * Default implementation delegates to decommissionExecutors, scheduler can override
    * if it supports graceful decommissioning.
    *
    * @param executorId identifiers of executor to decommission

core/src/main/scala/org/apache/spark/scheduler/dynalloc/ExecutorMonitor.scala

@@ -451,12 +451,12 @@ private[spark] class ExecutorMonitor(
   }
 
   // Visible for testing
-  def executorsPendingToRemove(): Set[String] = {
+  private[spark] def executorsPendingToRemove(): Set[String] = {
     executors.asScala.filter { case (_, exec) => exec.pendingRemoval }.keys.toSet
   }
 
   // Visible for testing
-  def executorsDecommissioning(): Set[String] = {
+  private[spark] def executorsDecommissioning(): Set[String] = {
     executors.asScala.filter { case (_, exec) => exec.pendingDecommissioning }.keys.toSet
   }
 

streaming/src/test/scala/org/apache/spark/streaming/scheduler/ExecutorAllocationManagerSuite.scala

@@ -96,7 +96,7 @@ class ExecutorAllocationManagerSuite extends TestSuiteBase
             Map.empty)}
       }
 
-      /** Verify that particular executors was killed */
+      /** Verify that a particular executor was scaled down. */
       def verifyKilledExec(expectedKilledExec: Option[String]): Unit = {
         if (expectedKilledExec.nonEmpty) {
           val decomInfo = ExecutorDecommissionInfo("spark scale down", false)