database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](deploy) K8s deploy manager cannot get group host info by endpoint (#27813)

Browse Source 
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.
This commit is contained in:
zxealous
2023-12-04 10:50:43 +08:00
committed by GitHub
parent d2a99aa03b
commit f8bdbf67b4
1 changed files with 15 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
fe/fe-core/src/main/java/org/apache/doris/deploy/impl/K8sDeployManager.java
View File

@ -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);
}
}