aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAndrew Ash <andrew@andrewash.com>2014-06-08 23:20:10 -0700
committerReynold Xin <rxin@apache.org>2014-06-08 23:20:10 -0700
commit32ee9f0668e50083e415b0662b18f5d2581413f0 (patch)
treee61ee529cc9ac17dd99c896dac8165b7cb8f35fa
parent15ddbef414d5fd6d4672936ba3c747b5fb7ab52b (diff)
downloadspark-32ee9f0668e50083e415b0662b18f5d2581413f0.tar.gz
spark-32ee9f0668e50083e415b0662b18f5d2581413f0.tar.bz2
spark-32ee9f0668e50083e415b0662b18f5d2581413f0.zip
Grammar: read -> reads
Author: Andrew Ash <andrew@andrewash.com> Closes #1016 from ash211/patch-6 and squashes the following commits: e3865c8 [Andrew Ash] Grammar: read -> reads
-rw-r--r--core/src/main/scala/org/apache/spark/storage/BlockManager.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala
index a41286d3e4..9cd79d262e 100644
--- a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala
+++ b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala
@@ -1024,7 +1024,7 @@ private[spark] class BlockManager(
if (blockId.isShuffle) {
// Reducer may need to read many local shuffle blocks and will wrap them into Iterators
// at the beginning. The wrapping will cost some memory (compression instance
- // 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
// wrapping lazily to save memory.
class LazyProxyIterator(f: => Iterator[Any]) extends Iterator[Any] {
lazy val proxy = f