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 39f4112..121ec25 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 @@ -298,7 +298,6 @@ protected Void performDataRead() throws IOException { } if (processStop()) { - cleanupReaders(); recordReaderTime(startTime); return null; } @@ -323,7 +322,6 @@ protected Void performDataRead() throws IOException { OrcBatchKey stripeKey = hasFileId ? new OrcBatchKey(fileKey, -1, 0) : null; for (int stripeIxMod = 0; stripeIxMod < readState.length; ++stripeIxMod) { if (processStop()) { - cleanupReaders(); recordReaderTime(startTime); return null; } @@ -393,7 +391,6 @@ protected Void performDataRead() throws IOException { return null; } if (processStop()) { - cleanupReaders(); recordReaderTime(startTime); return null; }