This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new 92fcd56fb6f branch-3.1: [fix](regression)Fix test_analyze_mv case.
#53352 (#53476)
92fcd56fb6f is described below
commit 92fcd56fb6f66fb8d8f1d340763181eb8e9b1103
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Jul 18 10:56:17 2025 +0800
branch-3.1: [fix](regression)Fix test_analyze_mv case. #53352 (#53476)
Cherry-picked from #53352
Co-authored-by: James <[email protected]>
---
.../suites/statistics/test_analyze_mv.groovy | 44 +++++++++++++++-------
1 file changed, 31 insertions(+), 13 deletions(-)
diff --git a/regression-test/suites/statistics/test_analyze_mv.groovy
b/regression-test/suites/statistics/test_analyze_mv.groovy
index aa8be109203..508aa538a83 100644
--- a/regression-test/suites/statistics/test_analyze_mv.groovy
+++ b/regression-test/suites/statistics/test_analyze_mv.groovy
@@ -680,20 +680,38 @@ suite("test_analyze_mv") {
empty_test = sql """show column stats mvTestDup"""
assertEquals(12, empty_test.size())
- for (int i = 0; i < 120; i++) {
- result_row = sql """show index stats mvTestDup mv3"""
- logger.info("mv3 stats: " + result_row)
- if (result_row[0][4] == "0") {
- break;
+ def result = sql """show frontends;"""
+ logger.info("show frontends result origin: " + result)
+ def host
+ def port
+ for (int i = 0; i < result.size(); i++) {
+ if (result[i][8] == "true") {
+ host = result[i][1]
+ port = result[i][4]
}
- Thread.sleep(5000)
}
- 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("0", result_row[0][3])
- assertEquals("0", result_row[0][4])
+ def tokens = context.config.jdbcUrl.split('/')
+ def url=tokens[0] + "//" + host + ":" + port
+ logger.info("Master url is " + url)
+ connect(context.config.jdbcUser, context.config.jdbcPassword, url) {
+ sql """use test_analyze_mv"""
+ result = sql """show frontends;"""
+ logger.info("show frontends result master: " + result)
+ for (int i = 0; i < 120; i++) {
+ result_row = sql """show index stats mvTestDup mv3"""
+ logger.info("mv3 stats: " + result_row)
+ if (result_row[0][4] == "0") {
+ break;
+ }
+ Thread.sleep(5000)
+ }
+ 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("0", result_row[0][3])
+ assertEquals("0", result_row[0][4])
+ }
// ** Embedded test for skip auto analyze when table is empty again
wait_row_count_reported("test_analyze_mv", "mvTestDup", 0, 4, "0")
@@ -725,7 +743,7 @@ suite("test_analyze_mv") {
sql """alter table mvTestDup index mv3 modify column mv_key1 set stats
('ndv'='5', 'num_nulls'='0', 'min_value'='0', 'max_value'='4',
'row_count'='5');"""
sql """alter table mvTestDup index mv3 modify column
`mva_SUM__CAST(``value1`` AS bigint)` set stats ('ndv'='10', 'num_nulls'='2',
'min_value'='1', 'max_value'='5', 'row_count'='11');"""
- def result = sql """show column cached stats mvTestDup(key1)"""
+ result = sql """show column cached stats mvTestDup(key1)"""
assertEquals(1, result.size())
assertEquals("key1", result[0][0])
assertEquals("mvTestDup", result[0][1])
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
