fix

dataroaring · Sep 13, 2024 · 01bfca7 · 01bfca7
1 parent 5984eb0
commit 01bfca7
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowClusterStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowClusterStmt.java
@@ -35,10 +35,10 @@
 
 public class ShowClusterStmt extends ShowStmt implements NotFallbackInParser {
     public static final ImmutableList<String> CLUSTER_TITLE_NAMES = new ImmutableList.Builder<String>()
-            .add("cluster").add("is_current").add("users").build();
+            .add("cluster").add("is_current").add("users").add("backend_num").build();
 
     public static final ImmutableList<String> COMPUTE_GROUP_TITLE_NAMES = new ImmutableList.Builder<String>()
-            .add("Name").add("IsCurrent").add("Users").build();
+            .add("Name").add("IsCurrent").add("Users").add("BackendNum").build();
 
     boolean isComputeGroup = true;
 

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ShowExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/ShowExecutor.java
@@ -823,8 +823,12 @@ private void handleShowCluster() throws AnalysisException {
                     PrivPredicate.of(PrivBitSet.of(Privilege.ADMIN_PRIV), Operator.OR))) {
                 users.removeIf(user -> !user.equals(ClusterNamespace.getNameFromFullName(ctx.getQualifiedUser())));
             }
+
             String result = Joiner.on(", ").join(users);
             row.add(result);
+            int backendNum = ((CloudSystemInfoService) Env.getCurrentEnv().getCurrentSystemInfo())
+                    .getBackendsByClusterName(clusterName).size();
+            row.add(String.valueOf(backendNum));
             rows.add(row);
         }