From ccd7310a9a966ef7431532b8a3e7c99cfa274a83 Mon Sep 17 00:00:00 2001
From: kangkaisen <kangkaisen@apache.org>
Date: Thu, 9 May 2019 15:32:02 +0800
Subject: [PATCH] Fix decommission BE bug

---
 .../main/java/org/apache/doris/alter/SystemHandler.java  | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/fe/src/main/java/org/apache/doris/alter/SystemHandler.java b/fe/src/main/java/org/apache/doris/alter/SystemHandler.java
index fc0265bc7b6450..e951f3439a4424 100644
--- a/fe/src/main/java/org/apache/doris/alter/SystemHandler.java
+++ b/fe/src/main/java/org/apache/doris/alter/SystemHandler.java
@@ -39,6 +39,7 @@
 import org.apache.doris.catalog.Table;
 import org.apache.doris.catalog.Table.TableType;
 import org.apache.doris.common.Config;
+import org.apache.doris.common.AnalysisException;
 import org.apache.doris.common.DdlException;
 import org.apache.doris.common.MetaNotFoundException;
 import org.apache.doris.common.Pair;
@@ -279,7 +280,13 @@ public static Map<String, Map<Long, Backend>> checkDecommission(List<Pair<String
             }
 
             // check if meet replication number requirement
-            List<String> dbNames = Catalog.getInstance().getDbNames();
+            List<String> dbNames;
+            try {
+                dbNames = Catalog.getInstance().getClusterDbNames(clusterName);
+            } catch (AnalysisException e) {
+                throw new DdlException(e.getMessage());
+            }
+
             for (String dbName : dbNames) {
                 Database db = Catalog.getInstance().getDb(dbName);
                 if (db == null) {