Use BufferedOutputStream.

nemccarthy · May 7, 2015 · 487f540 · 487f540
1 parent 8385f95
commit 487f540
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlSerializer2.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlSerializer2.scala
@@ -49,7 +49,7 @@ private[sql] class Serializer2SerializationStream(
     out: OutputStream)
   extends SerializationStream with Logging {
 
-  val rowOut = new DataOutputStream(out)
+  val rowOut = new DataOutputStream(new BufferedOutputStream(out))
   val writeKeyFunc = SparkSqlSerializer2.createSerializationFunction(keySchema, rowOut)
   val writeValueFunc = SparkSqlSerializer2.createSerializationFunction(valueSchema, rowOut)