This is an automated email from the ASF dual-hosted git repository.
yiguolei 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 3f997cedc94 [fix](cloud) Fix wrong error msg when not in cloud mode
(#31814)
3f997cedc94 is described below
commit 3f997cedc94f60365df277fdafe17697671b67f3
Author: zclllyybb <[email protected]>
AuthorDate: Wed Mar 6 20:39:26 2024 +0800
[fix](cloud) Fix wrong error msg when not in cloud mode (#31814)
---
fe/fe-core/src/main/java/org/apache/doris/planner/OlapScanNode.java | 2 +-
fe/fe-core/src/main/java/org/apache/doris/planner/OlapTableSink.java | 3 ++-
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/planner/OlapScanNode.java
b/fe/fe-core/src/main/java/org/apache/doris/planner/OlapScanNode.java
index 274725f3f22..11c402709f3 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/OlapScanNode.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/OlapScanNode.java
@@ -894,7 +894,7 @@ public class OlapScanNode extends ScanNode {
errs.add("replica " + replica.getId() + "'s backend " +
replica.getBackendId()
+ " does not exist or not alive");
errs.add(" or you may not have permission to access the
current cluster");
- if (ConnectContext.get() != null) {
+ if (ConnectContext.get() != null && Config.isCloudMode()) {
errs.add("clusterName=" +
ConnectContext.get().getCloudCluster());
}
continue;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/planner/OlapTableSink.java
b/fe/fe-core/src/main/java/org/apache/doris/planner/OlapTableSink.java
index 0d16a7dde90..bbfb4c95d21 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/OlapTableSink.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/OlapTableSink.java
@@ -45,6 +45,7 @@ import org.apache.doris.catalog.RangePartitionItem;
import org.apache.doris.catalog.Replica;
import org.apache.doris.catalog.Tablet;
import org.apache.doris.common.AnalysisException;
+import org.apache.doris.common.Config;
import org.apache.doris.common.DdlException;
import org.apache.doris.common.ErrorCode;
import org.apache.doris.common.ErrorReport;
@@ -513,7 +514,7 @@ public class OlapTableSink extends DataSink {
+ " < quorum replica num " +
loadRequiredReplicaNum
+ ", alive backends: [" +
StringUtils.join(bePathsMap.keySet(), ",") + "]";
errMsg += " or you may not have permission to access
the current cluster";
- if (ConnectContext.get() != null) {
+ if (ConnectContext.get() != null &&
Config.isCloudMode()) {
errMsg += " clusterName=" +
ConnectContext.get().getCloudCluster();
}
throw new
UserException(InternalErrorCode.REPLICA_FEW_ERR, errMsg);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
