File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed
sql/hive-thriftserver/v2.3/src/main/java/org/apache/hive/service/server Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -185,8 +185,11 @@ private void addServerInstanceToZooKeeper(HiveConf hiveConf) throws Exception {
185185 + ZOOKEEPER_PATH_SEPARATOR + queue + ZOOKEEPER_PATH_SEPARATOR + ephemeralPath ;
186186 LOG .info ("Add server instance to zookeeper on {}" , zkPath );
187187 try {
188+ String data = "{\" tag\" :[]}" ;
188189 String queueTag = hiveConf .get ("spark.yarn.queue.tag" , "" );
189- String data = "{\" tag\" :[\" " + queueTag + "\" ]}" ; // schedule
190+ if (StringUtils .isNotBlank (queueTag )) {
191+ data = "{\" tag\" :[\" " + queueTag + "\" ]}" ; // schedule
192+ }
190193 znode = new PersistentEphemeralNode (zooKeeperClient ,
191194 Mode .EPHEMERAL , zkPath , data .getBytes (StandardCharsets .UTF_8 ));
192195 znode .start ();
You can’t perform that action at this time.
0 commit comments