Repository: spark Updated Branches: refs/heads/branch-1.2 acf5c6328 -> 391080b68
SPARK-4971: Fix typo in BlockGenerator comment Author: CodingCat <[email protected]> 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 <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/391080b6 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/391080b6 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/391080b6 Branch: refs/heads/branch-1.2 Commit: 391080b68a1f701ab1f636704fa447334d4ca38e Parents: acf5c63 Author: CodingCat <[email protected]> Authored: Fri Dec 26 12:03:22 2014 -0800 Committer: Josh Rosen <[email protected]> Committed: Fri Dec 26 12:05:59 2014 -0800 ---------------------------------------------------------------------- .../scala/org/apache/spark/streaming/receiver/BlockGenerator.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/391080b6/streaming/src/main/scala/org/apache/spark/streaming/receiver/BlockGenerator.scala ---------------------------------------------------------------------- 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 55765dc..79263a7 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 { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
