From c2e7b19a12b7d6e3be0ae60bdb7048eb85a365d8 Mon Sep 17 00:00:00 2001
From: HHoflittlefish777 <77738092+HHoflittlefish777@users.noreply.github.com>
Date: Thu, 21 Dec 2023 10:38:02 +0800
Subject: [PATCH] [branch-2.0](regression) fix test stream load properties fail
 (#28681)

---
 .../test_stream_load_properties.groovy            | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy b/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
index 63c23bdf17e420..2666b5ad1a77a0 100644
--- a/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
+++ b/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
@@ -201,6 +201,7 @@ suite("test_stream_load_properties", "p0") {
                     assertEquals(0, json.NumberUnselectedRows)
                 }
             }
+            sql "sync"
             def tableName1 =  "stream_load_" + tableName
             if (i <= 3) {
                 qt_sql_timezone_shanghai "select * from ${tableName1} order by k00,k01"
@@ -242,6 +243,7 @@ suite("test_stream_load_properties", "p0") {
                     assertEquals(0, json.NumberUnselectedRows)
                 }
             }
+            sql "sync"
             def tableName1 =  "stream_load_" + tableName
             if (i <= 3) {
                 qt_sql_timezone_Abidjan "select * from ${tableName1} order by k00,k01"
@@ -286,6 +288,7 @@ suite("test_stream_load_properties", "p0") {
                     assertEquals(0, json.NumberUnselectedRows)
                 }
             }
+            sql "sync"
             def tableName1 =  "stream_load_" + tableName
             if (i <= 3) {
                 qt_sql_strict_mode "select * from ${tableName1} order by k00,k01"
@@ -329,6 +332,7 @@ suite("test_stream_load_properties", "p0") {
                     assertEquals(0, json.NumberUnselectedRows)
                 }
             }
+            sql "sync"
             def tableName1 =  "stream_load_" + tableName
             if (i <= 3) {
                 qt_sql_max_filter_ratio "select * from ${tableName1} order by k00,k01"
@@ -400,6 +404,7 @@ suite("test_stream_load_properties", "p0") {
                     assertEquals(0, json.NumberUnselectedRows)
                 }
             }
+            sql "sync"
             qt_sql_squence "select * from stream_load_uniq_tbl_basic_sequence order by k00,k01"
     } finally {
         sql new File("""${context.file.parent}/ddl/uniq_tbl_basic_drop_sequence.sql""").text
@@ -432,6 +437,7 @@ suite("test_stream_load_properties", "p0") {
                 assertEquals(0, json.NumberUnselectedRows)
             }
         }
+        sql "sync"
 
         streamLoad {
             table "stream_load_" + tableName
@@ -454,6 +460,7 @@ suite("test_stream_load_properties", "p0") {
                 assertEquals(0, json.NumberUnselectedRows)
             }
         }
+        sql "sync"
         def tableName1 = "stream_load_" + tableName
         qt_sql_merge_type "select * from ${tableName1} order by k00,k01"                  
     } finally {
@@ -532,6 +539,7 @@ suite("test_stream_load_properties", "p0") {
                     assertEquals(0, json.NumberUnselectedRows)
                 }
             }
+            sql "sync"
 
             def tableName1 =  "stream_load_" + tableName
             if (i <= 3) {
@@ -541,6 +549,7 @@ suite("test_stream_load_properties", "p0") {
             }
 
             do_streamload_2pc.call(txnId, "abort", tableName1)
+            sql "sync"
 
             if (i <= 3) {
                 qt_sql_2pc_abort "select * from ${tableName1} order by k00,k01"
@@ -570,8 +579,10 @@ suite("test_stream_load_properties", "p0") {
                     assertEquals(0, json.NumberUnselectedRows)
                 }
             }
+            sql "sync"
 
             do_streamload_2pc.call(txnId, "commit", tableName1)
+            sql "sync"
 
             def count = 0
             while (true) {
@@ -686,6 +697,7 @@ suite("test_stream_load_properties", "p0") {
                     assertEquals(0, json.NumberUnselectedRows)
                 }
             }
+            sql "sync"
             def tableName1 =  "stream_load_" + tableName
             if (i <= 3) {
                 qt_sql_skip_lines "select * from ${tableName1} order by k00,k01"
@@ -805,6 +817,7 @@ suite("test_stream_load_properties", "p0") {
                     assertEquals(0, json.NumberUnselectedRows)
                 }
             }
+            sql "sync"
             def tableName1 =  "stream_load_" + tableName
             if (i <= 3) {
                 qt_sql_json_strip_outer_array "select * from ${tableName1} order by k00,k01"
@@ -851,6 +864,7 @@ suite("test_stream_load_properties", "p0") {
                     assertEquals(0, json.NumberUnselectedRows)
                 }
             }
+            sql "sync"
             def tableName1 =  "stream_load_" + tableName
             if (i <= 3) {
                 qt_sql_json_jsonpath "select * from ${tableName1} order by k00,k01"
@@ -896,6 +910,7 @@ suite("test_stream_load_properties", "p0") {
                     assertEquals(0, json.NumberUnselectedRows)
                 }
             }
+            sql "sync"
             def tableName1 =  "stream_load_" + tableName
             if (i <= 3) {
                 qt_sql_json_read_by_line "select * from ${tableName1} order by k00,k01"