@@ -485,7 +485,9 @@ private Map<String, Set<String>> validateAndGetPartitions(TableIf table, Set<Str
         }
 
         if (analysisType == AnalysisType.FUNDAMENTALS) {
-            return table.findReAnalyzeNeededPartitions();
+            Map<String, Set<String>> result = table.findReAnalyzeNeededPartitions();
+            result.keySet().retainAll(columnNames);
+            return result;
         }
 
         return columnToPartitions;
 
@@ -1110,4 +1110,18 @@ PARTITION `p599` VALUES IN (599)
     sql """ANALYZE TABLE test_meta_management WITH SYNC"""
     afterDropped = sql """SHOW TABLE STATS test_meta_management"""
     assert check_column(afterDropped, "[col1, col2, col3]")
+
+    // test analyze specific column
+    sql """CREATE TABLE test_analyze_specific_column (col1 varchar(11451) not null, col2 int not null, col3 int not null)
+    DUPLICATE KEY(col1)
+    DISTRIBUTED BY HASH(col1)
+    BUCKETS 3
+    PROPERTIES(
+            "replication_num"="1"
+    );"""
+    sql """insert into test_analyze_specific_column values('%.', 2, 1);"""
+    sql """ANALYZE TABLE test_analyze_specific_column(col2) WITH SYNC"""
+    result = sql """SHOW COLUMN STATS test_analyze_specific_column"""
+    assert result.size() == 1
+
 }
Original file line number	Diff line number	Diff line change
`@@ -485,7 +485,9 @@ private Map<String, Set<String>> validateAndGetPartitions(TableIf table, Set<Str`
`485`	`485`	`}`
`486`	`486`
`487`	`487`	`if (analysisType == AnalysisType.FUNDAMENTALS) {`
`488`		`- return table.findReAnalyzeNeededPartitions();`
	`488`	`+ Map<String, Set<String>> result = table.findReAnalyzeNeededPartitions();`
	`489`	`+ result.keySet().retainAll(columnNames);`
	`490`	`+ return result;`
`489`	`491`	`}`
`490`	`492`
`491`	`493`	`return columnToPartitions;`