This is an automated email from the ASF dual-hosted git repository.
lijibing pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 7ff7f884dc5 Improve analyze mv/mtmv wait row count report logic.
(#33695) (#33751)
7ff7f884dc5 is described below
commit 7ff7f884dc5f6f335474f4d757d20110f45c2cf7
Author: Jibing-Li <[email protected]>
AuthorDate: Wed Apr 17 14:14:15 2024 +0800
Improve analyze mv/mtmv wait row count report logic. (#33695) (#33751)
---
regression-test/suites/statistics/test_analyze_mv.groovy | 14 +++++++++++---
1 file changed, 11 insertions(+), 3 deletions(-)
diff --git a/regression-test/suites/statistics/test_analyze_mv.groovy
b/regression-test/suites/statistics/test_analyze_mv.groovy
index c2f6d9b38ca..f5dcabb7a62 100644
--- a/regression-test/suites/statistics/test_analyze_mv.groovy
+++ b/regression-test/suites/statistics/test_analyze_mv.groovy
@@ -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;
}
}
@@ -422,7 +422,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;"""
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
