This is an automated email from the ASF dual-hosted git repository.
englefly pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 958d63831cd [fix](nereids)do not add delta row count to BE reported
row count (#41464)
958d63831cd is described below
commit 958d63831cddb99800842dc14cc4cd83c4498345
Author: minghong <[email protected]>
AuthorDate: Tue Oct 8 15:22:26 2024 +0800
[fix](nereids)do not add delta row count to BE reported row count (#41464)
## Proposed changes
the table row count is in 3 cases:
1. injected row count
2. analyzed row count + delta row count
3. BE reported row count.
in previous pr #40529, we added delta row count in all 3 cases
Issue Number: close #xxx
<!--Describe your changes.-->
---
.../main/java/org/apache/doris/nereids/stats/StatsCalculator.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculator.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculator.java
index 79a574dc3f7..3c70d4cd518 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculator.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculator.java
@@ -396,7 +396,7 @@ public class StatsCalculator extends
DefaultPlanVisitor<Statistics, Void> {
rowCount =
olapTable.getRowCountForIndex(olapScan.getSelectedIndexId(), true);
if (rowCount == -1) {
if (tableMeta != null) {
- rowCount =
tableMeta.getRowCount(olapScan.getSelectedIndexId());
+ rowCount =
tableMeta.getRowCount(olapScan.getSelectedIndexId()) +
computeDeltaRowCount(olapScan);
}
}
}
@@ -489,7 +489,7 @@ public class StatsCalculator extends
DefaultPlanVisitor<Statistics, Void> {
builder.putColumnStatistics(slot, colStatsBuilder.build());
}
checkIfUnknownStatsUsedAsKey(builder);
- builder.setRowCount(selectedPartitionsRowCount +
deltaRowCount);
+ builder.setRowCount(selectedPartitionsRowCount);
}
}
// 1. no partition is pruned, or
@@ -503,7 +503,7 @@ public class StatsCalculator extends
DefaultPlanVisitor<Statistics, Void> {
builder.putColumnStatistics(slot, colStatsBuilder.build());
}
checkIfUnknownStatsUsedAsKey(builder);
- builder.setRowCount(tableRowCount + deltaRowCount);
+ builder.setRowCount(tableRowCount);
}
return builder.build();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
