diff options
| author | CodingCat <zhunansjtu@gmail.com> | 2014-12-26 12:03:22 -0800 |
|---|---|---|
| committer | Josh Rosen <joshrosen@databricks.com> | 2014-12-26 12:04:46 -0800 |
| commit | fda4331d58aae454a2b0f4c757d105f8bc228a3d (patch) | |
| tree | 7035ee02b39d0fff7c76847ed98c9309b62c1806 /streaming | |
| parent | f9ed2b6641b9df39cee4b98a33cd5a3ddda2d146 (diff) | |
| download | spark-fda4331d58aae454a2b0f4c757d105f8bc228a3d.tar.gz spark-fda4331d58aae454a2b0f4c757d105f8bc228a3d.tar.bz2 spark-fda4331d58aae454a2b0f4c757d105f8bc228a3d.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
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/receiver/BlockGenerator.scala | 2 |
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 { |