Minor comment cleanup

apache · Jun 29, 2020 · 56a9903 · 56a9903
1 parent d97c6ee
commit 56a9903
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/core/src/test/scala/org/apache/spark/storage/BlockManagerDecommissionIntegrationSuite.scala b/core/src/test/scala/org/apache/spark/storage/BlockManagerDecommissionIntegrationSuite.scala
@@ -148,7 +148,7 @@ class BlockManagerDecommissionIntegrationSuite extends SparkFunSuite with LocalS
       ThreadUtils.awaitResult(asyncCount, 15.seconds)
     }
 
-    // Decommission one of the executor
+    // Decommission one of the executors.
     val sched = sc.schedulerBackend.asInstanceOf[StandaloneSchedulerBackend]
     val execs = sched.getExecutorIds()
     assert(execs.size == numExecs, s"Expected ${numExecs} executors but found ${execs.size}")
@@ -157,13 +157,12 @@ class BlockManagerDecommissionIntegrationSuite extends SparkFunSuite with LocalS
     logDebug(s"Decommissioning executor ${execToDecommission}")
     sched.decommissionExecutor(execToDecommission)
 
-    // Wait for job to finish
+    // Wait for job to finish.
     val asyncCountResult = ThreadUtils.awaitResult(asyncCount, 15.seconds)
     assert(asyncCountResult === numParts)
-    // All tasks finished, so accum should have been increased numParts times
+    // All tasks finished, so accum should have been increased numParts times.
     assert(accum.value === numParts)
 
-    // All tasks should be successful, nothing should have failed
     sc.listenerBus.waitUntilEmpty()
     if (shuffle) {
       //  mappers & reducers which succeeded