commit f9690d2fb26010dac69a016a8e55ada144e38cec Author: Owen O'Malley Date: Wed Mar 19 14:42:39 2014 -0700 HIVE-6699 Fix OrcRecordUpdater to use sync instead of flush. diff --git ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRecordUpdater.java ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRecordUpdater.java index f9cd76d..4012cfb 100644 --- ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRecordUpdater.java +++ ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRecordUpdater.java @@ -261,7 +261,7 @@ public void flush() throws IOException { } long len = writer.writeIntermediateFooter(); flushLengths.writeLong(len); - flushLengths.flush(); + flushLengths.sync(); } @Override diff --git ql/src/java/org/apache/hadoop/hive/ql/io/orc/WriterImpl.java ql/src/java/org/apache/hadoop/hive/ql/io/orc/WriterImpl.java index 904590b..96af148 100644 --- ql/src/java/org/apache/hadoop/hive/ql/io/orc/WriterImpl.java +++ ql/src/java/org/apache/hadoop/hive/ql/io/orc/WriterImpl.java @@ -2074,7 +2074,7 @@ public synchronized long writeIntermediateFooter() throws IOException { int footLength = writeFooter(rawWriter.getPos() - metaLength); rawWriter.writeByte(writePostScript(footLength, metaLength)); stripesAtLastFlush = stripes.size(); - rawWriter.flush(); + rawWriter.sync(); } return rawWriter.getPos(); }