[hive] branch master updated: HIVE-22523: The error handler in LlapRecordReader might block if its queue is full (Attila Magyar via Slim Bouguerra)

[bs...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

bslim pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git


The following commit(s) were added to refs/heads/master by this push:
     new 9c06b2c  HIVE-22523: The error handler in LlapRecordReader might block if its queue is full (Attila Magyar via Slim Bouguerra)
9c06b2c is described below

commit 9c06b2c32329824c202a6a45fb11f04820d827d5
Author: Attila Magyar <am...@cloudera.com>
AuthorDate: Tue Nov 26 10:08:56 2019 -0800

    HIVE-22523: The error handler in LlapRecordReader might block if its queue is full (Attila Magyar via Slim Bouguerra)
---
 .../java/org/apache/hadoop/hive/llap/io/api/impl/LlapRecordReader.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 77966aa..c2ee54c 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 @@ class LlapRecordReader implements RecordReader<NullWritable, VectorizedRowBatch>
   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<ColumnVectorBatch> feedback;
   private final QueryFragmentCounters counters;
   private long firstReturnTime;