From c68b4c54fe25ce81f6f5e01eb4c954a7fb0cdd2c Mon Sep 17 00:00:00 2001
From: Xianyang Liu <xianyang.liu@intel.com>
Date: Mon, 13 Nov 2017 06:19:13 -0600
Subject: [PATCH] [MINOR][CORE] Using bufferedInputStream for
dataDeserializeStream
## 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.
(cherry picked from commit 176ae4d53e0269cfc2cfa62d3a2991e28f5a9182)
Signed-off-by: Sean Owen <sowen@cloudera.com>
---
.../scala/org/apache/spark/serializer/SerializerManager.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/scala/org/apache/spark/serializer/SerializerManager.scala b/core/src/main/scala/org/apache/spark/serializer/SerializerManager.scala
index 311383e7ea..1d4b05caaa 100644
--- 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]]
}
}
--
GitLab