Fix the missed issue

YanTangZhai · Nov 12, 2014 · b798535 · b798535
1 parent e5e21c1
commit b798535
Showing 1 changed file with 1 addition and 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
@@ -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
   }