[doris] 01/03: [case](fix) add sync after stream load (#22601)

[kxiao]

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

kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git

commit ea9030ad778bdfd1793780909a65625c987b1b38
Author: Dongyang Li <hello_step...@qq.com>
AuthorDate: Sat Aug 5 08:28:26 2023 +0800

    [case](fix) add sync after stream load (#22601)
---
 regression-test/suites/load_p0/stream_load/test_json_load.groovy       | 3 ++-
 regression-test/suites/partition_p0/test_partition_operation.groovy    | 1 +
 .../unique_with_mow_p0/partial_update/test_partial_update.groovy       | 2 +-
 .../partial_update/test_partial_update_delete.groovy                   | 1 +
 .../partial_update/test_partial_update_parallel.groovy                 | 2 ++
 .../partial_update/test_partial_update_upsert.groovy                   | 1 +
 6 files changed, 8 insertions(+), 2 deletions(-)

diff --git a/regression-test/suites/load_p0/stream_load/test_json_load.groovy 
b/regression-test/suites/load_p0/stream_load/test_json_load.groovy
index c982196bb1..539eafe6ed 100644
--- a/regression-test/suites/load_p0/stream_load/test_json_load.groovy
+++ b/regression-test/suites/load_p0/stream_load/test_json_load.groovy
@@ -606,9 +606,10 @@ suite("test_json_load", "p0") {
             "replication_num" = "1"
         );
         """
-1
+
         load_json_data.call("${testTable}", 'with_jsonpath', '', 'true', 
'json', """productid, deviceid, data, datatimestamp, 
dt=from_unixtime(substr(datatimestamp,1,10),'%Y%m%d')""",
                 
'["$.productid","$.deviceid","$.data","$.data.datatimestamp"]', '', '', '', 
'with_jsonpath.json')
+        sql "sync"
         qt_select22 "select * from ${testTable}"
 
     } finally {
diff --git 
a/regression-test/suites/partition_p0/test_partition_operation.groovy 
b/regression-test/suites/partition_p0/test_partition_operation.groovy
index eae7f5fa38..05842a6532 100644
--- a/regression-test/suites/partition_p0/test_partition_operation.groovy
+++ b/regression-test/suites/partition_p0/test_partition_operation.groovy
@@ -44,6 +44,7 @@ suite("test_partition_operation", "p1") {
             set "column_separator", ","
             file "./multi_partition/partition_table.csv"
         }
+        sql """sync"""
         test {
             sql "select * from ${tableName} order by k1, k2"
             resultFile "./multi_partition/partition_table.out"
diff --git 
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update.groovy
 
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update.groovy
index e8538abd88..b8052cf525 100644
--- 
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update.groovy
+++ 
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update.groovy
@@ -172,7 +172,7 @@ suite("test_primary_key_partial_update", "p0") {
             assertEquals(2, json.NumberFilteredRows)
         }
     }
-
+    sql "sync"
     qt_partial_update_in_one_stream_load """
         select * from ${tableName} order by id;
     """
diff --git 
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_delete.groovy
 
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_delete.groovy
index 4022bb6d98..f8ed38c96f 100644
--- 
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_delete.groovy
+++ 
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_delete.groovy
@@ -90,6 +90,7 @@ suite('test_partial_update_delete') {
         file 'partial_update_delete.csv'
         time 10000
     }
+    sql "sync"
     qt_sql "select k1,c1,c2,c3,c4 from ${tableName3} order by k1,c1,c2,c3,c4;"
     sql "set skip_delete_sign=true;"
     sql "set skip_storage_engine_merge=true;"
diff --git 
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_parallel.groovy
 
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_parallel.groovy
index a6e15107e4..8875a5d6d4 100644
--- 
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_parallel.groovy
+++ 
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_parallel.groovy
@@ -82,6 +82,8 @@ suite("test_primary_key_partial_update_parallel", "p0") {
         }
     }
 
+    sql "sync"
+
     sql """
         select * from ${tableName} order by id;
     """
diff --git 
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_upsert.groovy
 
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_upsert.groovy
index 34d3c82d72..3c02ee3bb6 100644
--- 
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_upsert.groovy
+++ 
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_upsert.groovy
@@ -99,5 +99,6 @@ suite("test_partial_update_upsert", "p0") {
             assertEquals("fail", json.Status.toLowerCase())
         }
     }
+    sql "sync"
     sql """ DROP TABLE IF EXISTS ${tableName2} """
 }


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