You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2024/01/27 01:14:11 UTC
(doris) 26/31: [minor fix](use_fix_replica) handle set use_fix_replica < 0 (#30358)
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 <se...@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-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org