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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
