diff --git a/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java b/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java
index 4c03f49470..0fc355260e 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java
@@ -1799,15 +1799,18 @@ public class DatabaseTransactionMgr {
         }
         AnalysisManager analysisManager = Env.getCurrentEnv().getAnalysisManager();
         Map<Long, Long> tableIdToTotalNumDeltaRows = transactionState.getTableIdToTotalNumDeltaRows();
-        LOG.debug("table id to loaded rows:{}", tableIdToTotalNumDeltaRows);
         Map<Long, Long> tableIdToNumDeltaRows = Maps.newHashMap();
         tableIdToTotalNumDeltaRows
                         .forEach((tableId, numRows) -> {
                             OlapTable table = (OlapTable) db.getTableNullable(tableId);
                             if (table != null) {
-                                tableIdToNumDeltaRows.put(tableId, numRows / table.getReplicaCount());
+                                short replicaNum = table.getTableProperty()
+                                        .getReplicaAllocation()
+                                        .getTotalReplicaNum();
+                                tableIdToNumDeltaRows.put(tableId, numRows / replicaNum);
                             }
                         });
+        LOG.debug("table id to loaded rows:{}", tableIdToNumDeltaRows);
         tableIdToNumDeltaRows.forEach(analysisManager::updateUpdatedRows);
         return true;
     }