From b798535f1e6c8c981bfb700fe6083e881072d210 Mon Sep 17 00:00:00 2001
From: jerryshao <saisai.shao@intel.com>
Date: Wed, 12 Nov 2014 14:14:53 +0800
Subject: [PATCH] Fix the missed issue

---
 .../org/apache/spark/streaming/receiver/BlockGenerator.scala    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 e563c89dc8115..2e3be392189ba 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
@@ -84,7 +84,7 @@ private[streaming] class BlockGenerator(
    * Push a single data item into the buffer. All received data items
    * will be periodically pushed into BlockManager.
    */
-  def += (data: Any, metadata: Any = null): Unit = synchronized {
+  def += (data: Any): Unit = synchronized {
     waitToPush()
     currentBuffer += data
   }