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..2663bf6a8af 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; @@ -581,7 +582,6 @@ public void setError(Throwable t) throws InterruptedException { LlapIoImpl.LOG.warn("setError called with an error", t); assert t != null; pendingError.compareAndSet(null, t); - enqueueInternal(t); } private void enqueueInternal(Object o) throws InterruptedException {