Fix the missed issue

jerryshao · jerryshao · commit b798535f1e6c · 2014-11-12T14:14:53.000+08:00
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
   }

Original file line number	Diff line number	Diff line change
`@@ -84,7 +84,7 @@ private[streaming] class BlockGenerator(`
`84`	`84`	`* Push a single data item into the buffer. All received data items`
`85`	`85`	`* will be periodically pushed into BlockManager.`
`86`	`86`	`*/`
`87`		`- def += (data: Any, metadata: Any = null): Unit = synchronized {`
	`87`	`+ def += (data: Any): Unit = synchronized {`
`88`	`88`	`waitToPush()`
`89`	`89`	`currentBuffer += data`
`90`	`90`	`}`