diff --git a/llap-server/src/java/org/apache/hadoop/hive/llap/io/api/impl/LlapRecordReader.java b/llap-server/src/java/org/apache/hadoop/hive/llap/io/api/impl/LlapRecordReader.java index 77966aa9650..c2ee54c11ac 100644 --- a/llap-server/src/java/org/apache/hadoop/hive/llap/io/api/impl/LlapRecordReader.java +++ b/llap-server/src/java/org/apache/hadoop/hive/llap/io/api/impl/LlapRecordReader.java @@ -93,7 +93,8 @@ private boolean isFirst = true; private int maxQueueSize = 0; - private boolean isClosed = false, isInterrupted = false; + private volatile boolean isClosed = false; + private volatile boolean isInterrupted = false; private final ConsumerFeedback feedback; private final QueryFragmentCounters counters; private long firstReturnTime;