diff --git llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java index 69c0647..1befba7 100644 --- llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java +++ llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java @@ -561,6 +561,13 @@ private void cleanupReaders() { // Ignore. } } + if (metadataReader != null) { + try { + metadataReader.close(); + } catch (IOException ex) { + // Ignore. + } + } } /** @@ -857,6 +864,9 @@ public Allocator getAllocator() { @Override public void close() throws IOException { orcDataReader.close(); + if (metadataReader != null) { + metadataReader.close(); + } } @Override