fix

deardeng · Sep 6, 2024 · a2b0075 · a2b0075
1 parent 1a0bfcf
commit a2b0075
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudReplica.java b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudReplica.java
@@ -423,7 +423,7 @@ public long getIdx() {
  return idx;
  }
 
- public Map<String, List<Long>> getClusterToBackends() {
+ public Map<String, List<Long>> getprimaryClusterToBackends() {
  return primaryClusterToBackends;
  }
 

diff --git a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudTabletRebalancer.java b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudTabletRebalancer.java
@@ -499,9 +499,9 @@ private void completeRouteInfo() {
  List<Long> tabletIds = new ArrayList<Long>();
  for (Tablet tablet : index.getTablets()) {
  for (Replica replica : tablet.getReplicas()) {
- Map<String, List<Long>> clusterToBackends =
- ((CloudReplica) replica).getClusterToBackends();
- if (!clusterToBackends.containsKey(cluster)) {
+ Map<String, List<Long>> primaryClusterToBackends =
+ ((CloudReplica) replica).getprimaryClusterToBackends();
+ if (!primaryClusterToBackends.containsKey(cluster)) {
  long beId = ((CloudReplica) replica).hashReplicaToBe(cluster, true);
  ((CloudReplica) replica).updateClusterToBe(cluster, beId, true);
  if (beId <= 0) {
@@ -510,13 +510,13 @@ private void completeRouteInfo() {
  }
  List<Long> bes = new ArrayList<Long>();
  bes.add(beId);
- clusterToBackends.put(cluster, bes);
+ primaryClusterToBackends.put(cluster, bes);
 
  assigned = true;
  beIds.add(beId);
  tabletIds.add(tablet.getId());
  } else {
- beIds.add(clusterToBackends.get(cluster).get(0));
+ beIds.add(primaryClusterToBackends.get(cluster).get(0));
  tabletIds.add(tablet.getId());
  }
  }
@@ -570,9 +570,9 @@ public void statRouteInfo() {
  loopCloudReplica((Database db, Table table, Partition partition, MaterializedIndex index, String cluster) -> {
  for (Tablet tablet : index.getTablets()) {
  for (Replica replica : tablet.getReplicas()) {
- Map<String, List<Long>> clusterToBackends =
- ((CloudReplica) replica).getClusterToBackends();
- for (Map.Entry<String, List<Long>> entry : clusterToBackends.entrySet()) {
+ Map<String, List<Long>> primaryClusterToBackends =
+ ((CloudReplica) replica).getprimaryClusterToBackends();
+ for (Map.Entry<String, List<Long>> entry : primaryClusterToBackends.entrySet()) {
  if (!cluster.equals(entry.getKey())) {
  continue;
  }