diff --git a/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/AnalyzeTableTestBase.scala b/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/AnalyzeTableTestBase.scala
index 9e2ccb2d5ddc..dbe069be3f68 100644
--- a/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/AnalyzeTableTestBase.scala
+++ b/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/AnalyzeTableTestBase.scala
@@ -62,10 +62,11 @@ abstract class AnalyzeTableTestBase extends PaimonSparkTestBase {
 
     spark.sql(s"ANALYZE TABLE T COMPUTE STATISTICS")
 
-    val df = spark.sql("select snapshot_id, schema_id, schema_id, colstat from `T$statistics`")
+    val df =
+      spark.sql("select snapshot_id, schema_id, mergedRecordCount, colstat from `T$statistics`")
     Assertions.assertEquals(df.collect().size, 1)
     checkAnswer(
-      spark.sql("SELECT snapshot_id, schema_id, schema_id, colstat from `T$statistics`"),
+      spark.sql("SELECT snapshot_id, schema_id, mergedRecordCount, colstat from `T$statistics`"),
       Row(2, 0, 2, "{ }"))
   }