This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new bf7d7848794 [fix](cloud) fix cloud autobucket num (#34420)
bf7d7848794 is described below
commit bf7d7848794e6cbee20cd4da630942a1de34982c
Author: yujun <[email protected]>
AuthorDate: Mon May 6 19:53:59 2024 +0800
[fix](cloud) fix cloud autobucket num (#34420)
---
.../src/main/java/org/apache/doris/common/util/AutoBucketUtils.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/common/util/AutoBucketUtils.java
b/fe/fe-core/src/main/java/org/apache/doris/common/util/AutoBucketUtils.java
index 55a07b89eb8..f9291c4cea8 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/util/AutoBucketUtils.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/util/AutoBucketUtils.java
@@ -85,7 +85,7 @@ public class AutoBucketUtils {
public static int getBucketsNum(long partitionSize) {
int bucketsNumByPartitionSize =
convertParitionSizeToBucketsNum(partitionSize);
- int bucketsNumByBE = getBucketsNumByBEDisks();
+ int bucketsNumByBE = Config.isCloudMode() ? Integer.MAX_VALUE :
getBucketsNumByBEDisks();
int bucketsNum = Math.min(Config.autobucket_max_buckets,
Math.min(bucketsNumByPartitionSize, bucketsNumByBE));
int beNum = getBENum();
logger.debug("AutoBucketsUtil: bucketsNumByPartitionSize {},
bucketsNumByBE {}, bucketsNum {}, beNum {}",
@@ -93,6 +93,7 @@ public class AutoBucketUtils {
if (bucketsNum < bucketsNumByPartitionSize && bucketsNum < beNum) {
bucketsNum = beNum;
}
+ bucketsNum = Math.min(bucketsNum, Config.autobucket_max_buckets);
logger.debug("AutoBucketsUtil: final bucketsNum {}", bucketsNum);
return bucketsNum;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
