diff --git a/fe/fe-core/src/main/java/com/starrocks/sql/analyzer/CTASAnalyzer.java b/fe/fe-core/src/main/java/com/starrocks/sql/analyzer/CTASAnalyzer.java
index fa2d6cb7bbb2f..08558ce17ae0b 100644
--- a/fe/fe-core/src/main/java/com/starrocks/sql/analyzer/CTASAnalyzer.java
+++ b/fe/fe-core/src/main/java/com/starrocks/sql/analyzer/CTASAnalyzer.java
@@ -13,6 +13,7 @@
 import com.starrocks.catalog.OlapTable;
 import com.starrocks.catalog.Table;
 import com.starrocks.catalog.Type;
+import com.starrocks.common.Config;
 import com.starrocks.common.Pair;
 import com.starrocks.qe.ConnectContext;
 import com.starrocks.server.GlobalStateMgr;
@@ -141,7 +142,7 @@ public static void analyze(CreateTableAsSelectStmt createTableAsSelectStmt, Conn
                 }
             }
 
-            int defaultBucket = 10;
+            int defaultBucket = Config.default_bucket_num;
             DistributionDesc distributionDesc =
                     new HashDistributionDesc(defaultBucket, Lists.newArrayList(defaultColumnName));
             createTableStmt.setDistributionDesc(distributionDesc);