fix unstable test

924060929 · Apr 14, 2024 · 67bdf27 · 67bdf27
1 parent 03bd2a3
commit 67bdf27
Showing 1 changed file with 14 additions and 0 deletions.
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
@@ -291,6 +291,8 @@ suite("parse_sql_from_sql_cache") {
             sql "select * from test_use_plan_cache12"
             assertHasCache "select * from test_use_plan_cache12"
 
+            sql "sync"
+
 
             extraThread("test_cache_user1_thread", {
                 connect(user = "test_cache_user1", password="DORIS@2024") {
@@ -321,6 +323,8 @@ suite("parse_sql_from_sql_cache") {
             // after partition changed 10s, the sql cache can be used
             sleep(10000)
 
+            sql "sync"
+
             extraThread("test_cache_user2_thread", {
                 connect(user = "test_cache_user2", password="DORIS@2024") {
                     sql "use ${dbName}"
@@ -342,6 +346,8 @@ suite("parse_sql_from_sql_cache") {
                 USING (id = 'concat(id, "**")')"""
             sql "set enable_nereids_planner=true"
 
+            sql "sync"
+
             // after row policy changed, the cache is invalidate
             extraThread("test_cache_user2_thread2", {
                 connect(user = "test_cache_user2", password="DORIS@2024") {
@@ -377,6 +383,8 @@ suite("parse_sql_from_sql_cache") {
             USING (id = 'concat(id, "**")')"""
             sql "set enable_nereids_planner=true"
 
+            sql "sync"
+
             // after partition changed 10s, the sql cache can be used
             sleep(10000)
 
@@ -400,6 +408,8 @@ suite("parse_sql_from_sql_cache") {
             FOR test_cache_user3"""
             sql "set enable_nereids_planner=true"
 
+            sql "sync"
+
             // after row policy changed, the cache is invalidate
             extraThread("test_cache_user3_thread2", {
                 connect(user = "test_cache_user3", password="DORIS@2024") {
@@ -425,6 +435,8 @@ suite("parse_sql_from_sql_cache") {
             sql "GRANT SELECT_PRIV ON regression_test.* TO test_cache_user4"
             sql "GRANT SELECT_PRIV ON ${dbName}.test_use_plan_cache15 TO test_cache_user4"
 
+            sql "sync"
+
             extraThread("test_cache_user4_thread", {
                 connect(user = "test_cache_user4", password="DORIS@2024") {
                     sql "use ${dbName}"
@@ -440,6 +452,8 @@ suite("parse_sql_from_sql_cache") {
 
             sql "REVOKE SELECT_PRIV ON ${dbName}.test_use_plan_cache15 FROM test_cache_user4"
 
+            sql "sync"
+
             // after privileges changed, the cache is invalidate
             extraThread("test_cache_user4_thread2", {
                 connect(user = "test_cache_user4", password="DORIS@2024") {