We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 219dc00 commit e3865c8Copy full SHA for e3865c8
core/src/main/scala/org/apache/spark/storage/BlockManager.scala
@@ -1024,7 +1024,7 @@ private[spark] class BlockManager(
1024
if (blockId.isShuffle) {
1025
// Reducer may need to read many local shuffle blocks and will wrap them into Iterators
1026
// at the beginning. The wrapping will cost some memory (compression instance
1027
- // initialization, etc.). Reducer read shuffle blocks one by one so we could do the
+ // initialization, etc.). Reducer reads shuffle blocks one by one so we could do the
1028
// wrapping lazily to save memory.
1029
class LazyProxyIterator(f: => Iterator[Any]) extends Iterator[Any] {
1030
lazy val proxy = f
0 commit comments