[CARMEL-6525][MINOR] Support tag different drivers in the queue (#1237)

apache · Feb 15, 2023 · d8b4399 · d8b4399
1 parent c493098
commit d8b4399
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/server/HiveServer2.java b/sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/server/HiveServer2.java
@@ -185,8 +185,11 @@ private void addServerInstanceToZooKeeper(HiveConf hiveConf) throws Exception {
             + ZOOKEEPER_PATH_SEPARATOR + queue + ZOOKEEPER_PATH_SEPARATOR + ephemeralPath;
     LOG.info("Add server instance to zookeeper on {}", zkPath);
     try {
+      String data = "{\"tag\":[]}";
       String queueTag = hiveConf.get("spark.yarn.queue.tag", "");
-      String data = "{\"tag\":[\"" + queueTag + "\"]}"; // schedule
+      if (StringUtils.isNotBlank(queueTag)) {
+        data = "{\"tag\":[\"" + queueTag + "\"]}"; // schedule
+      }
       znode = new PersistentEphemeralNode(zooKeeperClient,
               Mode.EPHEMERAL, zkPath, data.getBytes(StandardCharsets.UTF_8));
       znode.start();