You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2023/06/03 08:34:19 UTC
[doris] 07/09: [Fix](dynamic-partition) Try to avoid setting a zero-bucket-size partition. (#20177)
This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 93698651b3843cc0ef77928025f4b7902dec9296
Author: Xiangyu Wang <du...@gmail.com>
AuthorDate: Wed May 31 13:09:03 2023 +0800
[Fix](dynamic-partition) Try to avoid setting a zero-bucket-size partition. (#20177)
A fallback to avoid BE crash problem when partition's bucket size is 0, but not resolved.
---
.../src/main/java/org/apache/doris/datasource/InternalCatalog.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
index 3e61fe8127..4b62de26ef 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
@@ -100,6 +100,7 @@ import org.apache.doris.catalog.PartitionInfo;
import org.apache.doris.catalog.PartitionItem;
import org.apache.doris.catalog.PartitionType;
import org.apache.doris.catalog.PrimitiveType;
+import org.apache.doris.catalog.RandomDistributionInfo;
import org.apache.doris.catalog.RangePartitionItem;
import org.apache.doris.catalog.Replica;
import org.apache.doris.catalog.Replica.ReplicaState;
@@ -1393,6 +1394,11 @@ public class InternalCatalog implements CatalogIf<Database> {
if (hashDistributionInfo.getBucketNum() <= 0) {
throw new DdlException("Cannot assign hash distribution buckets less than 1");
}
+ } else if (distributionInfo.getType() == DistributionInfoType.RANDOM) {
+ RandomDistributionInfo randomDistributionInfo = (RandomDistributionInfo) distributionInfo;
+ if (randomDistributionInfo.getBucketNum() <= 0) {
+ throw new DdlException("Cannot assign random distribution buckets less than 1");
+ }
}
} else {
// make sure partition-dristribution-info is deep copied from default-distribution-info
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org