database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

Improve analyze mv/mtmv wait row count report logic. (#33695)

Browse Source
This commit is contained in:
Jibing-Li
2024-04-17 09:56:44 +08:00
committed by yiguolei
parent ff8cb3cc43
commit f52067415b
2 changed files with 19 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
regression-test/suites/statistics/test_analyze_mtmv.groovy
View File

@ -17,7 +17,7 @@
suite("test_analyze_mtmv") {
def wait_row_count_reported = { db, table, expected ->
def wait_row_count_reported = { db, table, row, column, expected ->
def result = sql """show frontends;"""
logger.info("show frontends result origin: " + result)
def host
@ -39,7 +39,7 @@ suite("test_analyze_mtmv") {
Thread.sleep(5000)
result = sql """SHOW DATA FROM ${table};"""
logger.info("result " + result)
if (result[0][4] == expected) {
if (result[row][column] == expected) {
return;
}
}
@ -286,7 +286,12 @@ suite("test_analyze_mtmv") {
result_sample = sql """show column cached stats mv1(sum_total)"""
assertEquals(0, result_sample.size())
wait_row_count_reported("test_analyze_mtmv", "mv1", "3")
try {
wait_row_count_reported("test_analyze_mtmv", "mv1", 0, 4, "3")
} catch (Exception e) {
logger.info(e.getMessage());
return;
}
sql """analyze table mv1 with sync with sample rows 4000000"""
result_sample = sql """show column stats mv1(l_shipdate)"""
logger.info("result " + result_sample)

14
regression-test/suites/statistics/test_analyze_mv.groovy
View File

@ -35,7 +35,7 @@ suite("test_analyze_mv") {
throw new Exception("Wait mv finish timeout.")
}
def wait_row_count_reported = { db, table, expected ->
def wait_row_count_reported = { db, table, row, column, expected ->
def result = sql """show frontends;"""
logger.info("show frontends result origin: " + result)
def host
@ -57,7 +57,7 @@ suite("test_analyze_mv") {
Thread.sleep(5000)
result = sql """SHOW DATA FROM ${table};"""
logger.info("result " + result)
if (result[3][4] == expected) {
if (result[row][column] == expected) {
return;
}
}
@ -423,7 +423,15 @@ suite("test_analyze_mv") {
assertEquals(0, result_sample.size())
// Test sample
wait_row_count_reported("test_analyze_mv", "mvTestDup", "6")
try {
wait_row_count_reported("test_analyze_mv", "mvTestDup", 0, 4, "6")
wait_row_count_reported("test_analyze_mv", "mvTestDup", 1, 4, "6")
wait_row_count_reported("test_analyze_mv", "mvTestDup", 2, 4, "4")
wait_row_count_reported("test_analyze_mv", "mvTestDup", 3, 4, "6")
} catch (Exception e) {
logger.info(e.getMessage());
return;
}
sql """analyze table mvTestDup with sample rows 4000000"""
wait_analyze_finish("mvTestDup")
result_sample = sql """SHOW ANALYZE mvTestDup;"""