diff --git a/fe/src/main/java/org/apache/doris/catalog/Catalog.java b/fe/src/main/java/org/apache/doris/catalog/Catalog.java index 1e835ed1f397c9..aaa74901e9cbfb 100644 --- a/fe/src/main/java/org/apache/doris/catalog/Catalog.java +++ b/fe/src/main/java/org/apache/doris/catalog/Catalog.java @@ -2869,13 +2869,17 @@ public Pair addPartition(Database db, String tableName, OlapTab } if (distributionInfo.getType() == DistributionInfoType.HASH) { - List newDistriCols = ((HashDistributionInfo) distributionInfo).getDistributionColumns(); + HashDistributionInfo hashDistributionInfo = (HashDistributionInfo) distributionInfo; + List newDistriCols = hashDistributionInfo.getDistributionColumns(); List defaultDistriCols = ((HashDistributionInfo) defaultDistributionInfo) .getDistributionColumns(); if (!newDistriCols.equals(defaultDistriCols)) { throw new DdlException("Cannot assign hash distribution with different distribution cols. " + "default is: " + defaultDistriCols); } + if (hashDistributionInfo.getBucketNum() <= 0) { + throw new DdlException("Cannot assign hash distribution buckets less than 1"); + } } } else { distributionInfo = defaultDistributionInfo;