diff --git a/llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java b/llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java index 4f5b0a9..85fbe6e 100644 --- a/llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java +++ b/llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java @@ -434,6 +434,13 @@ private void handleReaderError(long startTime, Throwable t) throws InterruptedEx private void ensureDataReader() throws IOException { ensureOrcReader(); + if (stripeReader != null) { + try { + stripeReader.close(); + } catch (IOException ex) { + // Ignore. + } + } // Reader creation updates HDFS counters, don't do it here. DataWrapperForOrc dw = new DataWrapperForOrc(); stripeReader = orcReader.encodedReader(