diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java index 874e0dab17f194..7119533520d854 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java @@ -1261,7 +1261,7 @@ public String getCloudCluster(boolean updateErr) { choseWay = "default cluster"; } else { CloudClusterResult cloudClusterTypeAndName = getCloudClusterByPolicy(); - if (!Strings.isNullOrEmpty(cloudClusterTypeAndName.clusterName)) { + if (cloudClusterTypeAndName != null && !Strings.isNullOrEmpty(cloudClusterTypeAndName.clusterName)) { cluster = cloudClusterTypeAndName.clusterName; choseWay = "authorized cluster"; }