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
The following commit(s) were added to refs/heads/branch-2.1 by this push: new 74908c123a5 [fix](test)Fix unstable test drop index fault #38768 (#38772) 74908c123a5 is described below commit 74908c123a53d1bf946177c515244cdb01b9bbba Author: qiye <jianliang5...@gmail.com> AuthorDate: Sat Aug 3 23:47:55 2024 +0800 [fix](test)Fix unstable test drop index fault #38768 (#38772) ## Proposed changes bp #38768 <!--Describe your changes.--> --- ...index_builder_drop_index_fault_injection.groovy | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) diff --git a/regression-test/suites/fault_injection_p0/test_index_builder_drop_index_fault_injection.groovy b/regression-test/suites/fault_injection_p0/test_index_builder_drop_index_fault_injection.groovy index f8501f0e851..353afdf0769 100644 --- a/regression-test/suites/fault_injection_p0/test_index_builder_drop_index_fault_injection.groovy +++ b/regression-test/suites/fault_injection_p0/test_index_builder_drop_index_fault_injection.groovy @@ -18,6 +18,24 @@ import org.codehaus.groovy.runtime.IOGroovyMethods suite("test_index_builder_drop_index_fault_injection", "nonConcurrent") { + def timeout = 60000 + def delta_time = 1000 + def alter_res = "null" + def useTime = 0 + def wait_for_latest_op_on_table_finish = { table_name, OpTimeout -> + for(int t = delta_time; t <= OpTimeout; t += delta_time){ + alter_res = sql """SHOW ALTER TABLE COLUMN WHERE TableName = "${table_name}" ORDER BY CreateTime DESC LIMIT 1;""" + alter_res = alter_res.toString() + if(alter_res.contains("FINISHED")) { + sleep(3000) // wait change table state to normal + logger.info(table_name + " latest alter job finished, detail: " + alter_res) + break + } + useTime = t + sleep(delta_time) + } + assertTrue(useTime <= OpTimeout, "wait_for_latest_op_on_table_finish timeout") + } def runTest = { indexTbName -> sql """ insert into ${indexTbName} values(1, "json love anny", "json", "anny",1); """ sql "sync" @@ -33,6 +51,7 @@ suite("test_index_builder_drop_index_fault_injection", "nonConcurrent") { try { GetDebugPoint().enableDebugPointForAllBEs("index_builder.update_inverted_index_info.drop_index", [indexes_count: 3]) sql "DROP INDEX index_int ON ${indexTbName}" + wait_for_latest_op_on_table_finish(indexTbName, timeout) show_result = sql_return_maparray "show index from ${indexTbName}" logger.info("show index from " + indexTbName + " result: " + show_result) assertEquals(show_result.size(), 3) @@ -46,6 +65,7 @@ suite("test_index_builder_drop_index_fault_injection", "nonConcurrent") { try { GetDebugPoint().enableDebugPointForAllBEs("index_builder.update_inverted_index_info.drop_index", [indexes_count: 2]) sql "DROP INDEX index_str_k2 ON ${indexTbName}" + wait_for_latest_op_on_table_finish(indexTbName, timeout) show_result = sql_return_maparray "show index from ${indexTbName}" logger.info("show index from " + indexTbName + " result: " + show_result) assertEquals(show_result.size(), 2) @@ -58,6 +78,7 @@ suite("test_index_builder_drop_index_fault_injection", "nonConcurrent") { try { GetDebugPoint().enableDebugPointForAllBEs("index_builder.update_inverted_index_info.drop_index", [indexes_count: 1]) sql "DROP INDEX index_str_k4 ON ${indexTbName}" + wait_for_latest_op_on_table_finish(indexTbName, timeout) show_result = sql_return_maparray "show index from ${indexTbName}" logger.info("show index from " + indexTbName + " result: " + show_result) assertEquals(show_result.size(), 1) @@ -69,6 +90,7 @@ suite("test_index_builder_drop_index_fault_injection", "nonConcurrent") { try { GetDebugPoint().enableDebugPointForAllBEs("index_builder.update_inverted_index_info.drop_index", [indexes_count: 0]) sql "DROP INDEX index_k5 ON ${indexTbName}" + wait_for_latest_op_on_table_finish(indexTbName, timeout) show_result = sql_return_maparray "show index from ${indexTbName}" logger.info("show index from " + indexTbName + " result: " + show_result) assertEquals(show_result.size(), 0) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org