You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2017/11/04 19:45:01 UTC
hive git commit: HIVE-16856 : Allow For Customization Of Buffer Size
In MapJoinTableContainerSerDe (Beluga Behr via Ashutosh Chauhan)
Repository: hive
Updated Branches:
refs/heads/master 0c3ab791b -> 2d894a9ae
HIVE-16856 : Allow For Customization Of Buffer Size In MapJoinTableContainerSerDe (Beluga Behr via Ashutosh Chauhan)
Signed-off-by: Ashutosh Chauhan <ha...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/2d894a9a
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/2d894a9a
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/2d894a9a
Branch: refs/heads/master
Commit: 2d894a9ae8018f4b712cd9aaf8199d67a83c075c
Parents: 0c3ab79
Author: BELUGA BEHR <da...@gmail.com>
Authored: Wed Jun 7 21:01:00 2017 -0700
Committer: Ashutosh Chauhan <ha...@apache.org>
Committed: Sat Nov 4 12:44:12 2017 -0700
----------------------------------------------------------------------
.../hive/ql/exec/persistence/MapJoinTableContainerSerDe.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/2d894a9a/ql/src/java/org/apache/hadoop/hive/ql/exec/persistence/MapJoinTableContainerSerDe.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/persistence/MapJoinTableContainerSerDe.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/persistence/MapJoinTableContainerSerDe.java
index 9fd5611..badf6e9 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/persistence/MapJoinTableContainerSerDe.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/persistence/MapJoinTableContainerSerDe.java
@@ -138,7 +138,7 @@ public class MapJoinTableContainerSerDe {
InputStream is = null;
ObjectInputStream in = null;
try {
- is = fs.open(filePath, 4096);
+ is = fs.open(filePath);
in = new ObjectInputStream(is);
String name = in.readUTF();
Map<String, String> metaData = (Map<String, String>) in.readObject();
@@ -238,7 +238,7 @@ public class MapJoinTableContainerSerDe {
InputStream is = null;
ObjectInputStream in = null;
try {
- is = fs.open(filePath, 4096);
+ is = fs.open(filePath);
in = new ObjectInputStream(is);
// skip the name and metadata
in.readUTF();