0AyanamiRei commented on code in PR #57198:
URL: https://github.com/apache/doris/pull/57198#discussion_r2488824717
##########
fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java:
##########
@@ -3756,28 +3781,70 @@ public TCreatePartitionResult
createPartition(TCreatePartitionRequest request) t
} catch (UserException ex) {
errorStatus.setErrorMsgs(Lists.newArrayList(ex.getMessage()));
result.setStatus(errorStatus);
- LOG.warn("send create partition error status: {}",
result);
return result;
}
+
if (bePathsMap.keySet().size() < quorum) {
LOG.warn("auto go quorum exception");
}
- if (request.isSetWriteSingleReplica() &&
request.isWriteSingleReplica()) {
- Long[] nodes = bePathsMap.keySet().toArray(new
Long[0]);
- Random random = new SecureRandom();
- Long masterNode = nodes[random.nextInt(nodes.length)];
- Multimap<Long, Long> slaveBePathsMap = bePathsMap;
- slaveBePathsMap.removeAll(masterNode);
- tablets.add(new TTabletLocation(tablet.getId(),
-
Lists.newArrayList(Sets.newHashSet(masterNode))));
- slaveTablets.add(new TTabletLocation(tablet.getId(),
- Lists.newArrayList(slaveBePathsMap.keySet())));
- } else {
- tablets.add(new TTabletLocation(tablet.getId(),
Lists.newArrayList(bePathsMap.keySet())));
+
+ for (Long beId : bePathsMap.keySet()) {
+ Long selectedBeId = beId;
+
+ if (Config.isCloudMode()) {
+ DebugPoint debugPoint =
DebugPointUtil.getDebugPoint(
+
"FE.FrontendServiceImpl.createPartition.MockRebalance");
+ // 手动递增 executeNum 并获取递增后的值
Review Comment:
will remove this Chinese comment after this term of TEST done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
