[fix](statistics) use replication_num as replica num (apache#25325)

bobhan1 · Oct 13, 2023 · 6bb0c91 · 6bb0c91
1 parent 3e83fb8
commit 6bb0c91
Showing 1 changed file with 5 additions and 2 deletions.
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
@@ -1799,15 +1799,18 @@ private boolean updateCatalogAfterVisible(TransactionState transactionState, Dat
         }
         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;
     }