[branch-2.0](regression) fix test stream load properties fail (#28681)

apache · Dec 21, 2023 · c2e7b19 · c2e7b19
1 parent b2b5ba1
commit c2e7b19
Showing 1 changed file with 15 additions and 0 deletions.
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
@@ -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"