This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit d51cbf00f40ae8c26fe71ee9f833f2a84125c438 Author: zhiqiang <seuhezhiqi...@163.com> AuthorDate: Fri Jan 26 22:01:25 2024 +0800 [minor fix](use_fix_replica) handle set use_fix_replica < 0 (#30358) --- fe/fe-core/src/main/java/org/apache/doris/planner/OlapScanNode.java | 4 ++-- 1 file changed, 2 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 db7971b672e..ab7553e82d7 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 @@ -787,7 +787,7 @@ public class OlapScanNode extends ScanNode { throw new UserException(sb.toString()); } - if (useFixReplica == -1) { + if (useFixReplica <= -1) { if (skipMissingVersion) { // sort by replica's last success version, higher success version in the front. replicas.sort(Replica.LAST_SUCCESS_VERSION_COMPARATOR); @@ -795,7 +795,7 @@ public class OlapScanNode extends ScanNode { Collections.shuffle(replicas); } } else { - LOG.debug("use fix replica, value: {}, replica num: {}", useFixReplica, replicas.size()); + LOG.debug("use fix replica, value: {}, replica count: {}", useFixReplica, replicas.size()); // sort by replica id replicas.sort(Replica.ID_COMPARATOR); Replica replica = replicas.get(useFixReplica >= replicas.size() ? replicas.size() - 1 : useFixReplica); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org