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

lijibing 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 6ab8a7e5dfb [fix](p0)Fix case timeout. (#40788) (#40840)
6ab8a7e5dfb is described below

commit 6ab8a7e5dfb44722c3be67e04305e337d074bb47
Author: Jibing-Li <64681310+jibing...@users.noreply.github.com>
AuthorDate: Sat Sep 14 12:49:37 2024 +0800

    [fix](p0)Fix case timeout. (#40788) (#40840)
    
    backport: https://github.com/apache/doris/pull/40788
---
 .../suites/statistics/test_analyze_mtmv.groovy     | 23 ++++++++++++++--------
 .../suites/statistics/test_analyze_mv.groovy       |  1 +
 2 files changed, 16 insertions(+), 8 deletions(-)

diff --git a/regression-test/suites/statistics/test_analyze_mtmv.groovy 
b/regression-test/suites/statistics/test_analyze_mtmv.groovy
index 7e1bf8d2a92..98e76a7914f 100644
--- a/regression-test/suites/statistics/test_analyze_mtmv.groovy
+++ b/regression-test/suites/statistics/test_analyze_mtmv.groovy
@@ -123,14 +123,21 @@ suite("test_analyze_mtmv") {
            l_partkey,
            l_suppkey;
     """
-           sql """REFRESH MATERIALIZED VIEW mv1 AUTO"""
-           while(true) {
-                Thread.sleep(1000)
-               def result = sql """select * from 
mv_infos("database"="test_analyze_mtmv") where Name="mv1";"""
-               if (result[0][5] == "SUCCESS") {
-                   break;
-               }
-           }
+    sql """REFRESH MATERIALIZED VIEW mv1 AUTO"""
+    boolean refreshed = false;
+    for (int i = 0; i < 300; i++) {
+        Thread.sleep(1000)
+        def result = sql """select * from 
mv_infos("database"="test_analyze_mtmv") where Name="mv1";"""
+        logger.info("refresh mv info:" + result)
+        if (result[0][5] == "SUCCESS") {
+            refreshed = true;
+            break;
+        }
+        if (result[0][5] == "FAIL") {
+            throw new Exception("Refresh mv failed.")
+        }
+    }
+    assertTrue(refreshed)
 
     def dup_sql1 = """select * from mv1 order by l_shipdate;"""
            qt_sql1 dup_sql1
diff --git a/regression-test/suites/statistics/test_analyze_mv.groovy 
b/regression-test/suites/statistics/test_analyze_mv.groovy
index d5acedf6147..28c6607ce0c 100644
--- a/regression-test/suites/statistics/test_analyze_mv.groovy
+++ b/regression-test/suites/statistics/test_analyze_mv.groovy
@@ -111,6 +111,7 @@ suite("test_analyze_mv") {
     sql """drop database if exists test_analyze_mv"""
     sql """create database test_analyze_mv"""
     sql """use test_analyze_mv"""
+    sql """set global enable_auto_analyze=false"""
 
     sql """CREATE TABLE mvTestDup (
             key1 bigint NOT NULL,


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

Reply via email to