aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorAndrew Or <andrew@databricks.com>2015-06-03 16:04:02 -0700
committerAndrew Or <andrew@databricks.com>2015-06-03 16:04:02 -0700
commitbfbdab12dd37587e5518dcbb76507b752759cace (patch)
tree7024d6be60590495cbb358cad6f4347810d00d82 /core
parentd8662cd909a41575df6e0ea1630d2386d3711240 (diff)
downloadspark-bfbdab12dd37587e5518dcbb76507b752759cace.tar.gz
spark-bfbdab12dd37587e5518dcbb76507b752759cace.tar.bz2
spark-bfbdab12dd37587e5518dcbb76507b752759cace.zip
[HOTFIX] [TYPO] Fix typo in #6546
Diffstat (limited to 'core')
-rw-r--r--core/src/test/scala/org/apache/spark/ExternalShuffleServiceSuite.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/test/scala/org/apache/spark/ExternalShuffleServiceSuite.scala b/core/src/test/scala/org/apache/spark/ExternalShuffleServiceSuite.scala
index 5b127a070c..140012226f 100644
--- a/core/src/test/scala/org/apache/spark/ExternalShuffleServiceSuite.scala
+++ b/core/src/test/scala/org/apache/spark/ExternalShuffleServiceSuite.scala
@@ -56,11 +56,11 @@ class ExternalShuffleServiceSuite extends ShuffleSuite with BeforeAndAfterAll {
sc.env.blockManager.shuffleClient.getClass should equal(classOf[ExternalShuffleClient])
// In a slow machine, one slave may register hundreds of milliseconds ahead of the other one.
- // If we don't wait for all salves, it's possible that only one executor runs all jobs. Then
+ // If we don't wait for all slaves, it's possible that only one executor runs all jobs. Then
// all shuffle blocks will be in this executor, ShuffleBlockFetcherIterator will directly fetch
// local blocks from the local BlockManager and won't send requests to ExternalShuffleService.
// In this case, we won't receive FetchFailed. And it will make this test fail.
- // Therefore, we should wait until all salves are up
+ // Therefore, we should wait until all slaves are up
sc.jobProgressListener.waitUntilExecutorsUp(2, 10000)
val rdd = sc.parallelize(0 until 1000, 10).map(i => (i, 1)).reduceByKey(_ + _)