diff --git ql/src/java/org/apache/hadoop/hive/ql/io/orc/FileDump.java ql/src/java/org/apache/hadoop/hive/ql/io/orc/FileDump.java index 7a3f508..5d5b760 100644 --- ql/src/java/org/apache/hadoop/hive/ql/io/orc/FileDump.java +++ ql/src/java/org/apache/hadoop/hive/ql/io/orc/FileDump.java @@ -82,6 +82,7 @@ public static void main(String[] args) throws Exception { System.out.println(buf); } } + rows.close(); } } } diff --git ql/src/test/org/apache/hadoop/hive/ql/io/TestRCFile.java ql/src/test/org/apache/hadoop/hive/ql/io/TestRCFile.java index a5d9ef6..9d8009b 100644 --- ql/src/test/org/apache/hadoop/hive/ql/io/TestRCFile.java +++ ql/src/test/org/apache/hadoop/hive/ql/io/TestRCFile.java @@ -719,6 +719,7 @@ private void writeThenReadByRecordReader(int intervalRecordCount, while (rr.next(key, value)) { readCount++; } + rr.close(); System.out.println("The " + i + "th split read " + (readCount - previousReadCount)); }