.../hadoop/hive/ql/exec/persistence/MapJoinTableContainerSerDe.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 MapJoinTableContainer load( 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 metaData = (Map) in.readObject(); @@ -238,7 +238,7 @@ public MapJoinTableContainer loadFastContainer(MapJoinDesc mapJoinDesc, 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();