.../hadoop/hive/ql/parse/spark/SparkPartitionPruningSinkOperator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/spark/SparkPartitionPruningSinkOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/spark/SparkPartitionPruningSinkOperator.java index dd8ff01..94230fd 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/spark/SparkPartitionPruningSinkOperator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/spark/SparkPartitionPruningSinkOperator.java @@ -116,7 +116,7 @@ private void flushToFile() throws IOException { try { fsout = fs.create(path, numOfRepl); - out = new ObjectOutputStream(new BufferedOutputStream(fsout, 4096)); + out = new ObjectOutputStream(new BufferedOutputStream(fsout)); out.writeUTF(conf.getTargetColumnName()); buffer.writeTo(out); } catch (Exception e) {