File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
core/src/test/scala/org/apache/spark Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -56,11 +56,11 @@ class ExternalShuffleServiceSuite extends ShuffleSuite with BeforeAndAfterAll {
5656 sc.env.blockManager.shuffleClient.getClass should equal(classOf [ExternalShuffleClient ])
5757
5858 // In a slow machine, one slave may register hundreds of milliseconds ahead of the other one.
59- // If we don't wait for all salves , it's possible that only one executor runs all jobs. Then
59+ // If we don't wait for all slaves , it's possible that only one executor runs all jobs. Then
6060 // all shuffle blocks will be in this executor, ShuffleBlockFetcherIterator will directly fetch
6161 // local blocks from the local BlockManager and won't send requests to ExternalShuffleService.
6262 // In this case, we won't receive FetchFailed. And it will make this test fail.
63- // Therefore, we should wait until all salves are up
63+ // Therefore, we should wait until all slaves are up
6464 sc.jobProgressListener.waitUntilExecutorsUp(2 , 10000 )
6565
6666 val rdd = sc.parallelize(0 until 1000 , 10 ).map(i => (i, 1 )).reduceByKey(_ + _)
You can’t perform that action at this time.
0 commit comments