This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 5fdfe065dcc [branch-2.0](hint) add detail for replica missing msg
(#42548)
5fdfe065dcc is described below
commit 5fdfe065dccdc3e49a038c23f6364cef88a6eabb
Author: yujun <[email protected]>
AuthorDate: Tue Oct 29 09:45:10 2024 +0800
[branch-2.0](hint) add detail for replica missing msg (#42548)
---
.../src/main/java/org/apache/doris/clone/TabletScheduler.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 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 5ecbeb89d39..9dd4b22c436 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
@@ -82,6 +82,7 @@ import java.util.Optional;
import java.util.PriorityQueue;
import java.util.Queue;
import java.util.Set;
+import java.util.stream.Collectors;
/**
* TabletScheduler saved the tablets produced by TabletChecker and try to
schedule them.
@@ -1442,9 +1443,13 @@ public class TabletScheduler extends MasterDaemon {
List<BePathLoadStatPair> allFitPaths =
!allFitPathsSameMedium.isEmpty() ? allFitPathsSameMedium :
allFitPathsDiffMedium;
if (allFitPaths.isEmpty()) {
+ List<String> backendsInfo =
Env.getCurrentSystemInfo().getAllBackends().stream()
+ .filter(be -> be.getLocationTag() == tag)
+ .map(Backend::getDetailsForCreateReplica)
+ .collect(Collectors.toList());
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()));
+ + " for replica allocation { %s } with tag %s storage
medium %s, backends on this tag is: %s",
+ tabletCtx.getReplicaAlloc(), tag,
tabletCtx.getStorageMedium(), backendsInfo));
}
BePathLoadStatPairComparator comparator = new
BePathLoadStatPairComparator(allFitPaths);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
