From f8bdbf67b4eee46b6c0f54ecf82670aced97702a Mon Sep 17 00:00:00 2001
From: zxealous <zhouchangyue@baidu.com>
Date: Mon, 4 Dec 2023 10:50:43 +0800
Subject: [PATCH] [fix](deploy) K8s deploy manager cannot get group host info
 by endpoint (#27813)

K8s deploy manager cannot get group host info by endpoint. If we get group host info by endpoint, there is no need to init statefulset.
---
 .../doris/deploy/impl/K8sDeployManager.java   | 28 ++++++++++---------
 1 file changed, 15 insertions(+), 13 deletions(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/deploy/impl/K8sDeployManager.java b/fe/fe-core/src/main/java/org/apache/doris/deploy/impl/K8sDeployManager.java
index 5a182e8a6a..ee10a90073 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/deploy/impl/K8sDeployManager.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/deploy/impl/K8sDeployManager.java
@@ -117,20 +117,22 @@ public class K8sDeployManager extends DeployManager {
 
         LOG.info("use domainLTD: {}", domainLTD);
 
-        //Fill NodeTypeAttr.subAttr1 with statefulName
-        //If serviceName is configured, the corresponding statefulSetName must be configured
-        for (NodeType nodeType : NodeType.values()) {
-            NodeTypeAttr nodeTypeAttr = nodeTypeAttrMap.get(nodeType);
-            if (nodeTypeAttr.hasService()) {
-                String statefulSetEnvName = getStatefulSetEnvName(nodeType);
-                Log.info("Env name of: {} is: {}", nodeType.name(), statefulSetEnvName);
-                String statefulSetName = Strings.nullToEmpty(System.getenv(statefulSetEnvName));
-                if (Strings.isNullOrEmpty(statefulSetName)) {
-                    LOG.error("failed to init statefulSetName: {}", statefulSetEnvName);
-                    System.exit(-1);
+        if (Config.enable_fqdn_mode) {
+            //Fill NodeTypeAttr.subAttr1 with statefulName
+            //If serviceName is configured, the corresponding statefulSetName must be configured
+            for (NodeType nodeType : NodeType.values()) {
+                NodeTypeAttr nodeTypeAttr = nodeTypeAttrMap.get(nodeType);
+                if (nodeTypeAttr.hasService()) {
+                    String statefulSetEnvName = getStatefulSetEnvName(nodeType);
+                    Log.info("Env name of: {} is: {}", nodeType.name(), statefulSetEnvName);
+                    String statefulSetName = Strings.nullToEmpty(System.getenv(statefulSetEnvName));
+                    if (Strings.isNullOrEmpty(statefulSetName)) {
+                        LOG.error("failed to init statefulSetName: {}", statefulSetEnvName);
+                        System.exit(-1);
+                    }
+                    LOG.info("use statefulSetName: {}, {}", nodeType.name(), statefulSetName);
+                    nodeTypeAttr.setSubAttr(statefulSetName);
                 }
-                LOG.info("use statefulSetName: {}, {}", nodeType.name(), statefulSetName);
-                nodeTypeAttr.setSubAttr(statefulSetName);
             }
         }