(doris) 11/13: fix test_decimal256_index add wait build index (#31565)

[yiguolei]

This is an automated email from the ASF dual-hosted git repository.

yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git

commit 34a31e9fb96fbe9cf9df892b2aecf4068993299f
Author: Kang <kxiao.ti...@gmail.com>
AuthorDate: Thu Feb 29 16:35:50 2024 +0800

    fix test_decimal256_index add wait build index (#31565)
---
 .../decimalv3/test_decimal256_index.groovy         | 28 +++++++++++++++++++---
 1 file changed, 25 insertions(+), 3 deletions(-)

diff --git 
a/regression-test/suites/datatype_p0/decimalv3/test_decimal256_index.groovy 
b/regression-test/suites/datatype_p0/decimalv3/test_decimal256_index.groovy
index 8f7adef27db..04564ca3629 100644
--- a/regression-test/suites/datatype_p0/decimalv3/test_decimal256_index.groovy
+++ b/regression-test/suites/datatype_p0/decimalv3/test_decimal256_index.groovy
@@ -19,7 +19,7 @@ suite("test_decimal256_index") {
     sql "set enable_nereids_planner = true;"
     sql "set enable_decimal256 = true;"
 
-    def delta_time = 100
+    def delta_time = 1000
     def wait_for_latest_op_on_table_finish = { table_name, OpTimeout ->
         useTime = 0
         for(int t = delta_time; t <= OpTimeout; t += delta_time){
@@ -36,6 +36,27 @@ suite("test_decimal256_index") {
         assertTrue(useTime <= OpTimeout, "wait_for_latest_op_on_table_finish 
timeout")
     }
 
+    def wait_for_build_index_on_partition_finish = { table_name, OpTimeout ->
+        for(int t = delta_time; t <= OpTimeout; t += delta_time){
+            alter_res = sql """SHOW BUILD INDEX WHERE TableName = 
"${table_name}";"""
+            def expected_finished_num = alter_res.size();
+            def finished_num = 0;
+            for (int i = 0; i < expected_finished_num; i++) {
+                logger.info(table_name + " build index job state: " + 
alter_res[i][7] + i)
+                if (alter_res[i][7] == "FINISHED") {
+                    ++finished_num;
+                }
+            }
+            if (finished_num == expected_finished_num) {
+                logger.info(table_name + " all build index jobs finished, 
detail: " + alter_res)
+                break
+            }
+            useTime = t
+            sleep(delta_time)
+        }
+        assertTrue(useTime <= OpTimeout, 
"wait_for_latest_build_index_on_partition_finish timeout")
+    }
+
     // test zonemap index
     sql "DROP TABLE IF EXISTS `test_decimal256_zonemap_index`"
     sql """
@@ -117,9 +138,10 @@ suite("test_decimal256_index") {
     sql "sync"
 
     sql """CREATE INDEX k2_bitmap_index ON test_decimal256_bitmap_index(k2) 
USING BITMAP;"""
-    wait_for_latest_op_on_table_finish("test_decimal256_bitmap_index", 3000);
+    wait_for_latest_op_on_table_finish("test_decimal256_bitmap_index", 10000);
     sql """BUILD INDEX k2_bitmap_index ON test_decimal256_bitmap_index;"""
-    wait_for_latest_op_on_table_finish("test_decimal256_bitmap_index", 3000);
+    wait_for_latest_op_on_table_finish("test_decimal256_bitmap_index", 10000);
+    wait_for_build_index_on_partition_finish("test_decimal256_bitmap_index", 
10000)
 
     qt_sql_bitmap_index_select_all """
         select * from test_decimal256_bitmap_index order by 1,2,3;


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org