This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 e54210be284 [improvement](hint) update clone hint (#32466)
e54210be284 is described below
commit e54210be28402eba4a1f2b144192c87920feb010
Author: yujun <[email protected]>
AuthorDate: Tue Mar 19 21:53:57 2024 +0800
[improvement](hint) update clone hint (#32466)
---
.../src/main/java/org/apache/doris/clone/TabletScheduler.java | 4 +++-
.../src/main/java/org/apache/doris/planner/OlapTableSink.java | 7 ++++---
2 files changed, 7 insertions(+), 4 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/clone/TabletScheduler.java
b/fe/fe-core/src/main/java/org/apache/doris/clone/TabletScheduler.java
index 3e87e5004c9..0de9c5b6589 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/clone/TabletScheduler.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/clone/TabletScheduler.java
@@ -1467,7 +1467,9 @@ public class TabletScheduler extends MasterDaemon {
List<BePathLoadStatPair> allFitPaths =
!allFitPathsSameMedium.isEmpty() ? allFitPathsSameMedium :
allFitPathsDiffMedium;
if (allFitPaths.isEmpty()) {
- throw new SchedException(Status.UNRECOVERABLE, "unable to find
dest path for new replica");
+ throw new SchedException(Status.UNRECOVERABLE,
String.format("unable to find dest path for new replica"
+ + " for replica allocation { %s } with tag %s storage
medium %s",
+ tabletCtx.getReplicaAlloc(), tag,
tabletCtx.getStorageMedium()));
}
BePathLoadStatPairComparator comparator = new
BePathLoadStatPairComparator(allFitPaths);
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 19c6e7e1d5a..157c194131d 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
@@ -518,12 +518,13 @@ public class OlapTableSink extends DataSink {
Multimap<Long, Long> bePathsMap =
tablet.getNormalReplicaBackendPathMap();
if (bePathsMap.keySet().size() < loadRequiredReplicaNum) {
String errMsg = "tablet " + tablet.getId() + " alive
replica num " + bePathsMap.keySet().size()
- + " < load required replica num " +
loadRequiredReplicaNum
- + ", alive backends: [" +
StringUtils.join(bePathsMap.keySet(), ",") + "]";
+ + " < load required replica num " +
loadRequiredReplicaNum
+ + ", alive backends: [" +
StringUtils.join(bePathsMap.keySet(), ",") + "]"
+ + ", detail: " +
tablet.getDetailsStatusForQuery(partition.getVisibleVersion());
if (Config.isCloudMode()) {
errMsg += ", or you may not have permission to
access the current cluster";
if (ConnectContext.get() != null) {
- errMsg += " clusterName=" +
ConnectContext.get().getCloudCluster();
+ errMsg += " clusterName=" +
ConnectContext.get().getCloudCluster(false);
}
}
throw new
UserException(InternalErrorCode.REPLICA_FEW_ERR, errMsg);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
