This is an automated email from the ASF dual-hosted git repository.
jianliangqi 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 c3ed2d310ed [fix](test)Fix unstable index_change_with_cumu case
(#46527)
c3ed2d310ed is described below
commit c3ed2d310ed1cc9447e078eac9bc50fe96d14460
Author: qiye <l...@selectdb.com>
AuthorDate: Wed Jan 8 10:07:04 2025 +0800
[fix](test)Fix unstable index_change_with_cumu case (#46527)
---
...est_index_change_with_cumulative_compaction.groovy | 19 ++++++++++++++++++-
1 file changed, 18 insertions(+), 1 deletion(-)
diff --git
a/regression-test/suites/inverted_index_p0/index_change/test_index_change_with_cumulative_compaction.groovy
b/regression-test/suites/inverted_index_p0/index_change/test_index_change_with_cumulative_compaction.groovy
index 27789533420..ce12d1ede0c 100644
---
a/regression-test/suites/inverted_index_p0/index_change/test_index_change_with_cumulative_compaction.groovy
+++
b/regression-test/suites/inverted_index_p0/index_change/test_index_change_with_cumulative_compaction.groovy
@@ -40,6 +40,23 @@ suite("test_index_change_with_cumulative_compaction",
"nonConcurrent") {
assertTrue(useTime <= OpTimeout, "wait_for_latest_op_on_table_finish
timeout")
}
+ def trigger_compaction_with_retry = {table_name, compaction_type =
"cumulative", max_retries = 10, delay_ms = 2000 ->
+ def retry_count = 0
+ while (true) {
+ try {
+ trigger_and_wait_compaction(table_name, compaction_type)
+ return // Success
+ } catch (Exception e) {
+ retry_count++
+ if (retry_count >= max_retries) {
+ throw new Exception("Failed to complete ${compaction_type}
compaction after ${max_retries} attempts", e)
+ }
+ logger.warn("Compaction attempt ${retry_count} failed:
${e.getMessage()}")
+ Thread.sleep(delay_ms)
+ }
+ }
+ }
+
try {
//BackendId,Cluster,IP,HeartbeatPort,BePort,HttpPort,BrpcPort,LastStartTime,LastHeartbeat,Alive,SystemDecommissioned,ClusterDecommissioned,TabletNum,DataUsedCapacity,AvailCapacity,TotalCapacity,UsedPct,MaxDiskUsedPct,Tag,ErrMsg,Version,Status
String[][] backends = sql """ show backends; """
@@ -150,7 +167,7 @@ suite("test_index_change_with_cumulative_compaction",
"nonConcurrent") {
}
// trigger compactions for all tablets in ${tableName}
- trigger_and_wait_compaction(tableName, "cumulative")
+ trigger_compaction_with_retry(tableName, "cumulative")
int rowCount = 0
for (def tablet in tablets) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
