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 ba6ea4b995ada18664813d9eb34dd64194be4eaf
Author: morningman <[email protected]>
AuthorDate: Mon Aug 7 09:50:39 2023 +0800

    [tmp] add virtual node num config
---
 fe/fe-common/src/main/java/org/apache/doris/common/Config.java         | 3 +++
 .../org/apache/doris/planner/external/FederationBackendPolicy.java     | 3 ++-
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java 
b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
index 5b539a89a6..f288332a86 100644
--- a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
+++ b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
@@ -2039,4 +2039,7 @@ public class Config extends ConfigBase {
 
     @ConfField
     public static int statistics_sql_parallel_exec_instance_num = 1;
+
+    @ConfField
+    public static int virtual_node_num = 2048;
 }
diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/planner/external/FederationBackendPolicy.java
 
b/fe/fe-core/src/main/java/org/apache/doris/planner/external/FederationBackendPolicy.java
index daa1b151ea..a0f2c8110e 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/planner/external/FederationBackendPolicy.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/planner/external/FederationBackendPolicy.java
@@ -87,7 +87,8 @@ public class FederationBackendPolicy {
         if (backends.isEmpty()) {
             throw new UserException("No available backends");
         }
-        int virtualNumber = Math.max(Math.min(512 / backends.size(), 32), 2);
+        // int virtualNumber = Math.max(Math.min(512 / backends.size(), 32), 
2);
+        int virtualNumber = Config.virtual_node_num;
         consistentHash = new ConsistentHash<>(Hashing.murmur3_128(), new 
ScanRangeHash(),
                 new BackendHash(), backends, virtualNumber);
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to