This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 55ae9d60098a47ce1d55e12768538aa006af6b50
Author: AKIRA <33112463+kikyou1...@users.noreply.github.com>
AuthorDate: Wed Oct 18 19:42:41 2023 +0800
[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
---
.../main/java/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 b7fdec73f02..d7b90ebe457 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 {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
