From b00e64de9d2ef4cf1c4ab677d64e155860d4d4ff Mon Sep 17 00:00:00 2001
From: 924060929 <lanhuajian@selectdb.com>
Date: Mon, 6 Jan 2025 13:32:38 +0800
Subject: [PATCH] fix

---
 .../apache/doris/regression/suite/Suite.groovy   |  2 +-
 .../cache/parse_sql_from_sql_cache.groovy        | 16 ++++++++++++----
 2 files changed, 13 insertions(+), 5 deletions(-)

diff --git a/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy b/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
index 125b4ab193f6b1..698de2f809b9d0 100644
--- a/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
+++ b/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
@@ -702,7 +702,7 @@ class Suite implements GroovyInterceptable {
         return sql
     }
 
-    <T> T retry(int executeTimes = 3, int intervalMillis = 1000, Closure<T> closure) {
+    <T> T retry(int executeTimes = 3, int intervalMillis = 1000, Closure<Integer> closure) {
         Throwable throwable = null
         for (int i = 1; i <= executeTimes; ++i) {
             try {
diff --git a/regression-test/suites/nereids_p0/cache/parse_sql_from_sql_cache.groovy b/regression-test/suites/nereids_p0/cache/parse_sql_from_sql_cache.groovy
index c8e2741caa08af..057de371656a31 100644
--- a/regression-test/suites/nereids_p0/cache/parse_sql_from_sql_cache.groovy
+++ b/regression-test/suites/nereids_p0/cache/parse_sql_from_sql_cache.groovy
@@ -19,7 +19,10 @@ import java.util.stream.Collectors
 
 suite("parse_sql_from_sql_cache") {
     def assertHasCache = { String sqlStr ->
-        retry(120, 1000) {
+        retry(120, 1000) { i ->
+            if (i > 0) {
+                sql sqlStr
+            }
             explain {
                 sql ("physical plan ${sqlStr}")
                 contains("PhysicalSqlCache")
@@ -319,13 +322,13 @@ suite("parse_sql_from_sql_cache") {
 
             sql "sync"
 
-
             extraThread("test_cache_user1_thread", {
                 connect("test_cache_user1", "DORIS@2024") {
                     sql "use ${dbName}"
                     sql "set enable_nereids_planner=true"
                     sql "set enable_fallback_to_original_planner=false"
                     sql "set enable_sql_cache=true"
+                    sql "ADMIN SET FRONTEND CONFIG ('cache_last_version_interval_second' = '10')"
 
                     assertNoCache "select * from test_use_plan_cache12"
                 }
@@ -363,6 +366,7 @@ suite("parse_sql_from_sql_cache") {
                     sql "set enable_nereids_planner=true"
                     sql "set enable_fallback_to_original_planner=false"
                     sql "set enable_sql_cache=true"
+                    sql "ADMIN SET FRONTEND CONFIG ('cache_last_version_interval_second' = '10')"
 
                     assertNoCache "select * from test_use_plan_cache13"
                     sql "select * from test_use_plan_cache13"
@@ -385,6 +389,7 @@ suite("parse_sql_from_sql_cache") {
                     sql "set enable_nereids_planner=true"
                     sql "set enable_fallback_to_original_planner=false"
                     sql "set enable_sql_cache=true"
+                    sql "ADMIN SET FRONTEND CONFIG ('cache_last_version_interval_second' = '10')"
 
                     assertNoCache "select * from test_use_plan_cache13"
                 }
@@ -428,6 +433,7 @@ suite("parse_sql_from_sql_cache") {
                     sql "set enable_nereids_planner=true"
                     sql "set enable_fallback_to_original_planner=false"
                     sql "set enable_sql_cache=true"
+                    sql "ADMIN SET FRONTEND CONFIG ('cache_last_version_interval_second' = '10')"
 
                     assertNoCache "select * from test_use_plan_cache14"
                     sql "select * from test_use_plan_cache14"
@@ -449,6 +455,7 @@ suite("parse_sql_from_sql_cache") {
                     sql "set enable_nereids_planner=true"
                     sql "set enable_fallback_to_original_planner=false"
                     sql "set enable_sql_cache=true"
+                    sql "ADMIN SET FRONTEND CONFIG ('cache_last_version_interval_second' = '10')"
 
                     assertNoCache "select * from test_use_plan_cache14"
                 }
@@ -483,6 +490,7 @@ suite("parse_sql_from_sql_cache") {
                     sql "set enable_nereids_planner=true"
                     sql "set enable_fallback_to_original_planner=false"
                     sql "set enable_sql_cache=true"
+                    sql "ADMIN SET FRONTEND CONFIG ('cache_last_version_interval_second' = '10')"
 
                     assertNoCache "select * from test_use_plan_cache15"
                     sql "select * from test_use_plan_cache15"
@@ -500,6 +508,7 @@ suite("parse_sql_from_sql_cache") {
                     sql "set enable_nereids_planner=true"
                     sql "set enable_fallback_to_original_planner=false"
                     sql "set enable_sql_cache=true"
+                    sql "ADMIN SET FRONTEND CONFIG ('cache_last_version_interval_second' = '10')"
 
                     test {
                         sql ("select * from ${dbName}.test_use_plan_cache15")
@@ -659,8 +668,6 @@ suite("parse_sql_from_sql_cache") {
 
             log.info("connect to fe: ${fe1}")
             connect( context.config.jdbcUser,  context.config.jdbcPassword,  "jdbc:mysql://${fe1}") {
-                sql "ADMIN SET FRONTEND CONFIG ('cache_last_version_interval_second' = '10')"
-
                 sql "use ${dbName}"
 
                 createTestTable "test_use_plan_cache18"
@@ -688,6 +695,7 @@ suite("parse_sql_from_sql_cache") {
                 sql "set enable_nereids_planner=true"
                 sql "set enable_fallback_to_original_planner=false"
                 sql "set enable_sql_cache=true"
+                sql "ADMIN SET FRONTEND CONFIG ('cache_last_version_interval_second' = '10')"
 
                 assertNoCache "select * from test_use_plan_cache18"
                 sql "select * from test_use_plan_cache18"