You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by li...@apache.org on 2017/07/01 10:13:13 UTC
hive git commit: HIVE-16857: SparkPartitionPruningSinkOperator Buffer
Size (BELUGA BEHR reviewed by Rui)
Repository: hive
Updated Branches:
refs/heads/master 14733c7cf -> bec80e8c1
HIVE-16857: SparkPartitionPruningSinkOperator Buffer Size (BELUGA BEHR reviewed by Rui)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/bec80e8c
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/bec80e8c
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/bec80e8c
Branch: refs/heads/master
Commit: bec80e8c116d9379cb3e100b7cdff131243020de
Parents: 14733c7
Author: BELUGA BEHR <da...@gmail.com>
Authored: Sat Jul 1 18:13:06 2017 +0800
Committer: Rui Li <li...@apache.org>
Committed: Sat Jul 1 18:13:06 2017 +0800
----------------------------------------------------------------------
.../hive/ql/parse/spark/SparkPartitionPruningSinkOperator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/bec80e8c/ql/src/java/org/apache/hadoop/hive/ql/parse/spark/SparkPartitionPruningSinkOperator.java
----------------------------------------------------------------------
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 @@ public class SparkPartitionPruningSinkOperator extends Operator<SparkPartitionPr
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) {