diff --git a/llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java b/llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java index 48501e5e39..565afdc90b 100644 --- a/llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java +++ b/llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java @@ -16,6 +16,7 @@ import com.google.common.io.ByteArrayDataOutput; +import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.hive.llap.tezplugins.metrics.LlapMetricsCollector; import org.apache.hadoop.io.Text; import org.apache.hadoop.metrics2.MetricsSource; @@ -1088,7 +1089,9 @@ public void dagComplete() { } finally { writeLock.unlock(); } - updateGuaranteedInRegistry(tgVersionForZk, 0); + if (!StringUtils.isEmpty(conf.get(ConfVars.HIVE_SERVER2_TEZ_INTERACTIVE_QUEUE.varname, "").trim())) { + updateGuaranteedInRegistry(tgVersionForZk, 0); + } // TODO Cleanup pending tasks etc, so that the next dag is not affected. }