Skip to content

Commit 1cd8653

Browse files
author
jx158167
committed
resolve doc and test's name
1 parent 110c851 commit 1cd8653

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -587,8 +587,8 @@ object ShuffleBlockFetcherIterator {
587587
* Result of a fetch from a remote block successfully.
588588
* @param blockId block id
589589
* @param address BlockManager that the block was fetched from.
590-
* @param size estimated size of the block, used to calculate bytesInFlight.
591-
* Note that this is NOT the exact bytes.
590+
* @param size estimated size of the block. Note that this is NOT the exact bytes.
591+
* Size of remote block is used to calculate bytesInFlight.
592592
* @param buf `ManagedBuffer` for the content.
593593
* @param isNetworkReqDone Is this the last network request for this host in this fetch request.
594594
*/

core/src/test/scala/org/apache/spark/storage/ShuffleBlockFetcherIteratorSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -352,7 +352,7 @@ class ShuffleBlockFetcherIteratorSuite extends SparkFunSuite with PrivateMethodT
352352
intercept[FetchFailedException] { iterator.next() }
353353
}
354354

355-
test("big corrupt blocks will not be retiried") {
355+
test("big blocks are not checked for corruption") {
356356
val corruptStream = mock(classOf[InputStream])
357357
when(corruptStream.read(any(), any(), any())).thenThrow(new IOException("corrupt"))
358358
val corruptBuffer = mock(classOf[ManagedBuffer])

0 commit comments

Comments
 (0)