This is an automated email from the ASF dual-hosted git repository.
airborne pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 9f9d4c2d47c [Test](build index) enhance build index with clone test
case with retry logic (#42348)
9f9d4c2d47c is described below
commit 9f9d4c2d47cad7475f008ca205e1cd20350596cc
Author: airborne12 <airborn...@gmail.com>
AuthorDate: Thu Oct 24 10:50:13 2024 +0800
[Test](build index) enhance build index with clone test case with retry
logic (#42348)
## Proposed changes
Fix case error as below
```
Exception in
fault_injection_p0/test_build_index_with_clone_fault.groovy(line 89):
ADMIN SET REPLICA STATUS PROPERTIES("tablet_id" = "${tablet.TabletId}",
"backend_id" = "${tablet.BackendId}", "status" = "drop");
"""
// create index on table
sql """ create index idx_k2 on ${tbl}(k2) using inverted """
sql """ build index idx_k2 on ${tbl} """
// sleep 5s to wait for the build index job report table is unstable
sleep(5000)
def show_build_index = sql_return_maparray("show build index where
TableName = \"${tbl}\" ORDER BY JobId DESC LIMIT 1")
assertEquals('WAITING_TXN', show_build_index[0].State)
assertEquals('table is unstable', show_build_index[0].Msg)
^^^^^^^^^^^^^^^^^^^^^^^^^ERROR LINE^^^^^^^^^^^^^^^^^^^^^^^^^
def state = wait_for_last_build_index_on_table_finish(tbl, timeout)
assertEquals(state, "FINISHED")
} finally
{ GetDebugPoint().disableDebugPointForAllBEs("EngineCloneTask.wait_clone") }
}
Exception:
org.opentest4j.AssertionFailedError: expected: <table is unstable> but was:
<>
```
---
.../test_build_index_with_clone_fault.groovy | 32 ++++++++++++++++++++--
1 file changed, 29 insertions(+), 3 deletions(-)
diff --git
a/regression-test/suites/fault_injection_p0/test_build_index_with_clone_fault.groovy
b/regression-test/suites/fault_injection_p0/test_build_index_with_clone_fault.groovy
index 07fcfbe1a94..156a582f553 100644
---
a/regression-test/suites/fault_injection_p0/test_build_index_with_clone_fault.groovy
+++
b/regression-test/suites/fault_injection_p0/test_build_index_with_clone_fault.groovy
@@ -53,6 +53,33 @@ suite("test_build_index_with_clone_fault_injection",
"nonConcurrent"){
return "wait_timeout"
}
+ def assertShowBuildIndexWithRetry = { tbl, expectedState, expectedMsg,
maxRetries, waitSeconds ->
+ int attempt = 0
+ while (attempt < maxRetries) {
+ def show_build_index = sql_return_maparray("show build index where
TableName = \"${tbl}\" ORDER BY JobId DESC LIMIT 1")
+ if (show_build_index && show_build_index.size() > 0) {
+ def currentState = show_build_index[0].State
+ def currentMsg = show_build_index[0].Msg
+ if (currentState == expectedState && currentMsg ==
expectedMsg) {
+ logger.info("Attempt ${attempt + 1}: State and Msg match
expected values.")
+ return
+ } else {
+ logger.warn("Attempt ${attempt + 1}: Expected
State='${expectedState}' and Msg='${expectedMsg}', but got
State='${currentState}' and Msg='${currentMsg}'. Retrying after ${waitSeconds}
second(s)...")
+ }
+ } else {
+ logger.warn("Attempt ${attempt + 1}: show_build_index is empty
or null. Retrying after ${waitSeconds} second(s)...")
+ }
+ attempt++
+ if (attempt < maxRetries) {
+ sleep(waitSeconds * 1000)
+ }
+ }
+ def finalBuildIndex = sql_return_maparray("show build index where
TableName = \"${tbl}\" ORDER BY JobId DESC LIMIT 1")
+ assertTrue(finalBuildIndex && finalBuildIndex.size() > 0,
"show_build_index is empty or null after ${maxRetries} attempts")
+ assertEquals(expectedState, finalBuildIndex[0].State, "State does not
match after ${maxRetries} attempts")
+ assertEquals(expectedMsg, finalBuildIndex[0].Msg, "Msg does not match
after ${maxRetries} attempts")
+ }
+
def tbl = 'test_build_index_with_clone'
try {
GetDebugPoint().enableDebugPointForAllBEs("EngineCloneTask.wait_clone")
@@ -84,9 +111,8 @@ suite("test_build_index_with_clone_fault_injection",
"nonConcurrent"){
sql """ build index idx_k2 on ${tbl} """
// sleep 5s to wait for the build index job report table is unstable
sleep(5000)
- def show_build_index = sql_return_maparray("show build index where
TableName = \"${tbl}\" ORDER BY JobId DESC LIMIT 1")
- assertEquals('WAITING_TXN', show_build_index[0].State)
- assertEquals('table is unstable', show_build_index[0].Msg)
+
+ assertShowBuildIndexWithRetry(tbl, 'WAITING_TXN', 'table is unstable',
3, 5)
def state = wait_for_last_build_index_on_table_finish(tbl, timeout)
assertEquals(state, "FINISHED")
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
