diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java index f495be2..1fce282 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java @@ -546,13 +546,11 @@ static long getLastFlushLength(FileSystem fs, Path deltaFile) throws IOException { Path lengths = OrcRecordUpdater.getSideFile(deltaFile); long result = Long.MAX_VALUE; - try { - FSDataInputStream stream = fs.open(lengths); + try (FSDataInputStream stream = fs.open(lengths)) { result = -1; while (stream.available() > 0) { result = stream.readLong(); } - stream.close(); return result; } catch (IOException ioe) { return result;