diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/KeysDesc.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/KeysDesc.java index 0076ce74de3351..4ead25ab8e0deb 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/analysis/KeysDesc.java +++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/KeysDesc.java @@ -113,7 +113,9 @@ public void analyze(List cols) throws AnalysisException { } if (clusterKeysColumnNames != null) { - analyzeClusterKeys(cols); + // analyzeClusterKeys(cols); + // forbid cluster key in 3.0 temporarily + throw new AnalysisException("Cluster key is not supported"); } } diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateTableInfo.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateTableInfo.java index 442546224c08ca..0e3c037ecc390c 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateTableInfo.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateTableInfo.java @@ -777,6 +777,10 @@ private void validateKeyColumns() { } } + if (!clusterKeysColumnNames.isEmpty()) { + // forbid cluster key in 3.0 temporarily + throw new AnalysisException("Cluster key is not supported"); + } if (!clusterKeysColumnNames.isEmpty()) { // the same code as KeysDesc#analyzeClusterKeys if (Config.isCloudMode()) {