aboutsummaryrefslogtreecommitdiff
path: root/streaming
diff options
context:
space:
mode:
authorCodingCat <zhunansjtu@gmail.com>2014-12-26 12:03:22 -0800
committerJosh Rosen <joshrosen@databricks.com>2014-12-26 12:05:59 -0800
commit391080b68a1f701ab1f636704fa447334d4ca38e (patch)
treefefaf6195b5100a9a19f0893c32e87f763017dd4 /streaming
parentacf5c63289506c66c621175bb3da1f4633005770 (diff)
downloadspark-391080b68a1f701ab1f636704fa447334d4ca38e.tar.gz
spark-391080b68a1f701ab1f636704fa447334d4ca38e.tar.bz2
spark-391080b68a1f701ab1f636704fa447334d4ca38e.zip
SPARK-4971: Fix typo in BlockGenerator comment
Author: CodingCat <zhunansjtu@gmail.com> Closes #3807 from CodingCat/new_branch and squashes the following commits: 5167f01 [CodingCat] fix typo in the comment (cherry picked from commit fda4331d58aae454a2b0f4c757d105f8bc228a3d) Signed-off-by: Josh Rosen <joshrosen@databricks.com>
Diffstat (limited to 'streaming')
-rw-r--r--streaming/src/main/scala/org/apache/spark/streaming/receiver/BlockGenerator.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/receiver/BlockGenerator.scala b/streaming/src/main/scala/org/apache/spark/streaming/receiver/BlockGenerator.scala
index 55765dc906..79263a7183 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/receiver/BlockGenerator.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/receiver/BlockGenerator.scala
@@ -116,7 +116,7 @@ private[streaming] class BlockGenerator(
/**
* Push a single data item into the buffer. After buffering the data, the
- * `BlockGeneratorListnere.onAddData` callback will be called. All received data items
+ * `BlockGeneratorListener.onAddData` callback will be called. All received data items
* will be periodically pushed into BlockManager.
*/
def addDataWithCallback(data: Any, metadata: Any) = synchronized {