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

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


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new f43d9d92706 [Test](count on index) enhance count on index case 
retrying for statistics #42699 (#42887)
f43d9d92706 is described below

commit f43d9d92706c6914f3418431da5231e517bb434d
Author: airborne12 <airborn...@gmail.com>
AuthorDate: Wed Oct 30 13:15:24 2024 +0800

    [Test](count on index) enhance count on index case retrying for statistics 
#42699 (#42887)
    
    cherry pick from #42699
---
 .../inverted_index_p0/test_count_on_index.groovy   | 26 ++++++++++++++++++++--
 1 file changed, 24 insertions(+), 2 deletions(-)

diff --git 
a/regression-test/suites/inverted_index_p0/test_count_on_index.groovy 
b/regression-test/suites/inverted_index_p0/test_count_on_index.groovy
index 0143f37997a..c0e7e6845d2 100644
--- a/regression-test/suites/inverted_index_p0/test_count_on_index.groovy
+++ b/regression-test/suites/inverted_index_p0/test_count_on_index.groovy
@@ -145,9 +145,31 @@ suite("test_count_on_index_httplogs", "p0") {
         sql """set experimental_enable_nereids_planner=true;"""
         sql """set enable_fallback_to_original_planner=false;"""
         sql """analyze table ${testTable_dup} with sync""";
-        // wait BE report every partition's row count
-        sleep(10000)
         // case1: test duplicate table
+        def maxRetries = 3
+        def attempt = 0
+        def success = false
+
+        while (attempt < maxRetries && !success) {
+            try {
+                explain {
+                    sleep(10000)
+                    sql("select COUNT() from ${testTable_dup}")
+                    notContains("cardinality=0")
+                }
+                success = true
+            } catch (Exception e) {
+                attempt++
+                log.error("Attempt ${attempt} failed: ${e.message}")
+                if (attempt < maxRetries) {
+                    log.info("Retrying... (${attempt + 1}/${maxRetries})")
+                    sleep(1000)
+                } else {
+                    log.error("All ${maxRetries} attempts failed.")
+                    throw e
+                }
+            }
+        }
         explain {
             sql("select COUNT() from ${testTable_dup} where request match 
'GET'")
             contains "pushAggOp=COUNT_ON_INDEX"


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

Reply via email to