This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new ef9fb726f4d [fix](regression) stabilize index change wait (#65197)
(#67615)
ef9fb726f4d is described below
commit ef9fb726f4d80624a19891e6c7262cf2a7a92d53
Author: Chenyang Sun <[email protected]>
AuthorDate: Tue Sep 8 07:45:47 2026 +0800
[fix](regression) stabilize index change wait (#65197) (#67615)
pick from master #65197
Co-authored-by: shuke <[email protected]>
---
.../index_change/test_index_change_6.groovy | 15 +++++++++------
1 file changed, 9 insertions(+), 6 deletions(-)
diff --git
a/regression-test/suites/inverted_index_p0/index_change/test_index_change_6.groovy
b/regression-test/suites/inverted_index_p0/index_change/test_index_change_6.groovy
index 2f158285e08..5d8a0c9ab87 100644
---
a/regression-test/suites/inverted_index_p0/index_change/test_index_change_6.groovy
+++
b/regression-test/suites/inverted_index_p0/index_change/test_index_change_6.groovy
@@ -18,15 +18,15 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("test_index_change_6", "nonConcurrent") {
- def timeout = 60000
+ def timeout = 300000
def delta_time = 1000
- def alter_res = "null"
- def useTime = 0
sql "set enable_add_index_for_new_data = true"
def wait_for_build_index_on_partition_finish = { table_name, OpTimeout ->
- for(int t = delta_time; t <= OpTimeout; t += delta_time){
+ def finished = false
+ def alter_res = []
+ for(int t = 0; 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;
@@ -38,12 +38,15 @@ suite("test_index_change_6", "nonConcurrent") {
}
if (finished_num == expected_finished_num) {
logger.info(table_name + " all build index jobs finished,
detail: " + alter_res)
+ finished = true
+ break
+ }
+ if (t >= OpTimeout) {
break
}
- useTime = t
sleep(delta_time)
}
- assertTrue(useTime <= OpTimeout,
"wait_for_latest_build_index_on_partition_finish timeout")
+ assertTrue(finished, "wait_for_build_index_on_partition_finish
timeout, latest result: ${alter_res}")
}
def tableName = "test_index_change_6"
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
