This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new b6b7eab8d48 [fix](cloud) Fix cloud fe cluster metrics not registered
in FOLLOWER (#51377)
b6b7eab8d48 is described below
commit b6b7eab8d48dc78ea5b747d15bdd8e68fbceed78
Author: deardeng <[email protected]>
AuthorDate: Mon Jun 2 10:37:02 2025 +0800
[fix](cloud) Fix cloud fe cluster metrics not registered in FOLLOWER
(#51377)
---
.../main/java/org/apache/doris/cloud/catalog/CloudClusterChecker.java | 1 -
.../main/java/org/apache/doris/cloud/system/CloudSystemInfoService.java | 2 +-
2 files changed, 1 insertion(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudClusterChecker.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudClusterChecker.java
index fb0803bed17..49198536444 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudClusterChecker.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudClusterChecker.java
@@ -106,7 +106,6 @@ public class CloudClusterChecker extends MasterDaemon {
// For old versions that do no have status field set
ClusterStatus clusterStatus =
remoteClusterIdToPB.get(addId).hasClusterStatus()
? remoteClusterIdToPB.get(addId).getClusterStatus() :
ClusterStatus.NORMAL;
- MetricRepo.registerCloudMetrics(clusterId, clusterName);
List<Backend> toAdd = new ArrayList<>();
for (Cloud.NodeInfoPB node :
remoteClusterIdToPB.get(addId).getNodesList()) {
String addr = Config.enable_fqdn_mode ? node.getHost() :
node.getIp();
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/system/CloudSystemInfoService.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/system/CloudSystemInfoService.java
index 2d698a5fc86..7c8af713fb1 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/system/CloudSystemInfoService.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/system/CloudSystemInfoService.java
@@ -236,7 +236,6 @@ public class CloudSystemInfoService extends
SystemInfoService {
if (be == null) {
be = new ArrayList<>();
clusterIdToBackend.put(clusterId, be);
- MetricRepo.registerCloudMetrics(clusterId, clusterName);
}
Set<String> existed = be.stream().map(i -> i.getHost() + ":" +
i.getHeartbeatPort())
.collect(Collectors.toSet());
@@ -251,6 +250,7 @@ public class CloudSystemInfoService extends
SystemInfoService {
sortBackends.add(b);
Collections.sort(sortBackends,
Comparator.comparing(Backend::getId));
clusterIdToBackend.put(clusterId, sortBackends);
+ MetricRepo.registerCloudMetrics(clusterId, clusterName);
LOG.info("update (add) cloud cluster map, clusterName={}
clusterId={} backendNum={} current backend={}",
clusterName, clusterId, sortBackends.size(), sortBackends);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
