This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 3dbd7736202 branch-3.0: [fix](regression)Fix test_analyze_mv #54727
(#54880)
3dbd7736202 is described below
commit 3dbd773620240c36252c5df2ef3c13a5d5f2b347
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Aug 15 21:57:28 2025 +0800
branch-3.0: [fix](regression)Fix test_analyze_mv #54727 (#54880)
Cherry-picked from #54727
Co-authored-by: James <[email protected]>
---
.../doris/transaction/DatabaseTransactionMgr.java | 4 ++++
.../suites/statistics/test_analyze_mv.groovy | 28 ++++++++++++++++------
2 files changed, 25 insertions(+), 7 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
index 119571b7b29..3db8edb8659 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
@@ -2264,6 +2264,10 @@ public class DatabaseTransactionMgr {
}
replica.updateVersionWithFailed(newVersion,
lastFailedVersion, lastSuccessVersion);
if (newVersion == Partition.PARTITION_INIT_VERSION
+ 1) {
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("{}.{}, index {} first loaded,
set reported to false.",
+ db.getName(), table.getName(),
index.getId());
+ }
index.setRowCountReported(false);
}
long beId = replica.getBackendIdWithoutException();
diff --git a/regression-test/suites/statistics/test_analyze_mv.groovy
b/regression-test/suites/statistics/test_analyze_mv.groovy
index 508aa538a83..33179586e88 100644
--- a/regression-test/suites/statistics/test_analyze_mv.groovy
+++ b/regression-test/suites/statistics/test_analyze_mv.groovy
@@ -699,8 +699,10 @@ suite("test_analyze_mv") {
logger.info("show frontends result master: " + result)
for (int i = 0; i < 120; i++) {
result_row = sql """show index stats mvTestDup mv3"""
+ def result_row1 = sql """show index stats mvTestDup mvTestDup"""
logger.info("mv3 stats: " + result_row)
- if (result_row[0][4] == "0") {
+ logger.info("mvTestDup stats: " + result_row1)
+ if (result_row[0][4] == "0" && result_row1[0][4] == "0") {
break;
}
Thread.sleep(5000)
@@ -711,6 +713,12 @@ suite("test_analyze_mv") {
assertEquals("mv3", result_row[0][1])
assertEquals("0", result_row[0][3])
assertEquals("0", result_row[0][4])
+ result_row = sql """show index stats mvTestDup mvTestDup"""
+ assertEquals(1, result_row.size())
+ assertEquals("mvTestDup", result_row[0][0])
+ assertEquals("mvTestDup", result_row[0][1])
+ assertEquals("0", result_row[0][3])
+ assertEquals("0", result_row[0][4])
}
// ** Embedded test for skip auto analyze when table is empty again
@@ -718,7 +726,6 @@ suite("test_analyze_mv") {
sql """analyze table mvTestDup properties ("use.auto.analyzer" = "true")"""
empty_test = sql """show auto analyze mvTestDup"""
assertEquals(0, empty_test.size())
- empty_test = sql """show column stats mvTestDup"""
for (int i = 0; i < 100; i++) {
empty_test = sql """show column stats mvTestDup"""
if (empty_test.size() == 0) {
@@ -731,11 +738,18 @@ suite("test_analyze_mv") {
// ** End of embedded test
sql """insert into mvTestDup values (1, 2, 3, 4, 5), (1, 2, 3, 4, 5), (10,
20, 30, 40, 50), (10, 20, 30, 40, 50), (100, 200, 300, 400, 500), (1001, 2001,
3001, 4001, 5001);"""
- result_row = sql """show index stats mvTestDup mv3"""
- assertEquals(1, result_row.size())
- assertEquals("mvTestDup", result_row[0][0])
- assertEquals("mv3", result_row[0][1])
- assertEquals("-1", result_row[0][4])
+ connect(context.config.jdbcUser, context.config.jdbcPassword, url) {
+ sql """use test_analyze_mv"""
+ for (int i = 0; i < 10; i++) {
+ result_row = sql """show index stats mvTestDup mvTestDup"""
+ if (result_row[0][4] == "-1") {
+ break;
+ }
+ logger.info("row count for mvTestDup is not -1: " + result_row)
+ Thread.sleep(1000)
+ }
+ assertEquals("-1", result_row[0][4])
+ }
// Test alter column stats
sql """drop stats mvTestDup"""
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
