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
index ea4ffcadc2efa..b30ce9a551388 100644
--- 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)