This is an automated email from the ASF dual-hosted git repository. panxiaolei pushed a commit to branch dev_syxj_2 in repository https://gitbox.apache.org/repos/asf/doris.git
commit a525ceeab3d0986c387b023b9c4c713f26b92bc0 Author: morningman <[email protected]> AuthorDate: Tue Aug 1 11:08:59 2023 +0800 [tmp] do not shuffle BE when select for external table query --- .../src/main/java/org/apache/doris/system/BeSelectionPolicy.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/system/BeSelectionPolicy.java b/fe/fe-core/src/main/java/org/apache/doris/system/BeSelectionPolicy.java index 3a711307bd..1de33b6ae3 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/system/BeSelectionPolicy.java +++ b/fe/fe-core/src/main/java/org/apache/doris/system/BeSelectionPolicy.java @@ -26,7 +26,7 @@ import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import java.util.ArrayList; -import java.util.Collections; +//import java.util.Collections; import java.util.List; import java.util.Set; import java.util.stream.Collectors; @@ -165,7 +165,7 @@ public class BeSelectionPolicy { if (!preLocationFilterBackends.isEmpty()) { filterBackends = preLocationFilterBackends; } - Collections.shuffle(filterBackends); + // Collections.shuffle(filterBackends); List<Backend> candidates = new ArrayList<>(); if (preferComputeNode) { int num = 0; @@ -191,7 +191,7 @@ public class BeSelectionPolicy { } else { candidates.addAll(filterBackends); } - Collections.shuffle(candidates); + // Collections.shuffle(candidates); return candidates; } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
