From 9e07291e65a40eeac322a31986ae294b51c33408 Mon Sep 17 00:00:00 2001 From: AKIRA <33112463+Kikyou1997@users.noreply.github.com> Date: Wed, 18 Oct 2023 19:42:41 +0800 Subject: [PATCH] [fix](stats) internal stats table tablet replica num not update as expected (#25563) Before this PR, scale would not happen, since in the previous implementation relica count of all tablets was considered --- .../org/apache/doris/catalog/InternalSchemaInitializer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/InternalSchemaInitializer.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/InternalSchemaInitializer.java index b7fdec73f0..d7b90ebe45 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/InternalSchemaInitializer.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/InternalSchemaInitializer.java @@ -101,8 +101,8 @@ public class InternalSchemaInitializer extends Thread { TableIf colStatsTbl = StatisticsUtil.findTable(InternalCatalog.INTERNAL_CATALOG_NAME, StatisticConstants.DB_NAME, tblName); OlapTable olapTable = (OlapTable) colStatsTbl; - Partition partition = olapTable.getPartition(olapTable.getName()); - if (partition.getReplicaCount() >= StatisticConstants.STATISTIC_INTERNAL_TABLE_REPLICA_NUM) { + if (olapTable.getTableProperty().getReplicaAllocation().getTotalReplicaNum() + >= StatisticConstants.STATISTIC_INTERNAL_TABLE_REPLICA_NUM) { return; } try {