[MINOR][CORE] Using bufferedInputStream for dataDeserializeStream

ConeyLiu · srowen · commit 176ae4d53e02 · 2017-11-13T06:19:13.000-06:00
## What changes were proposed in this pull request? Small fix. Using bufferedInputStream for dataDeserializeStream. ## How was this patch tested? Existing UT. Author: Xianyang Liu <xianyang.liu@intel.com> Closes #19735 from ConeyLiu/smallfix.
diff --git a/core/src/main/scala/org/apache/spark/serializer/SerializerManager.scala b/core/src/main/scala/org/apache/spark/serializer/SerializerManager.scala
@@ -206,7 +206,7 @@ private[spark] class SerializerManager(
     val autoPick = !blockId.isInstanceOf[StreamBlockId]
     getSerializer(classTag, autoPick)
       .newInstance()
-      .deserializeStream(wrapForCompression(blockId, inputStream))
+      .deserializeStream(wrapForCompression(blockId, stream))
       .asIterator.asInstanceOf[Iterator[T]]
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -206,7 +206,7 @@ private[spark] class SerializerManager(`
`206`	`206`	`val autoPick = !blockId.isInstanceOf[StreamBlockId]`
`207`	`207`	`getSerializer(classTag, autoPick)`
`208`	`208`	`.newInstance()`
`209`		`- .deserializeStream(wrapForCompression(blockId, inputStream))`
	`209`	`+ .deserializeStream(wrapForCompression(blockId, stream))`
`210`	`210`	`.asIterator.asInstanceOf[Iterator[T]]`
`211`	`211`	`}`
`212`	`212`	`}`