cherry pick from #38971
This commit is contained in:
@ -72,6 +72,9 @@ public class DistributionDescriptor {
|
||||
* analyze distribution descriptor
|
||||
*/
|
||||
public void validate(Map<String, ColumnDefinition> columnMap, KeysType keysType) {
|
||||
if (bucketNum <= 0) {
|
||||
throw new AnalysisException("Buckets number of distribution should be greater than zero.");
|
||||
}
|
||||
if (isHash) {
|
||||
Set<String> colSet = Sets.newHashSet(cols);
|
||||
if (colSet.size() != cols.size()) {
|
||||
|
||||
Reference in New Issue
Block a user