We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8385f95 commit 487f540Copy full SHA for 487f540
sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlSerializer2.scala
@@ -49,7 +49,7 @@ private[sql] class Serializer2SerializationStream(
49
out: OutputStream)
50
extends SerializationStream with Logging {
51
52
- val rowOut = new DataOutputStream(out)
+ val rowOut = new DataOutputStream(new BufferedOutputStream(out))
53
val writeKeyFunc = SparkSqlSerializer2.createSerializationFunction(keySchema, rowOut)
54
val writeValueFunc = SparkSqlSerializer2.createSerializationFunction(valueSchema, rowOut)
55
0 commit comments