[doris] 05/05: [fix](regression) fix flaky regression test delete_mow_partial_update (#22548)

[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 45156cb0fac36aef3e6f414942cf922dbe154ff4
Author: bobhan1 <bh2444151...@outlook.com>
AuthorDate: Thu Aug 3 19:26:42 2023 +0800

    [fix](regression) fix flaky regression test delete_mow_partial_update 
(#22548)
---
 .../suites/nereids_p0/delete/delete_mow_partial_update.groovy      | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/regression-test/suites/nereids_p0/delete/delete_mow_partial_update.groovy 
b/regression-test/suites/nereids_p0/delete/delete_mow_partial_update.groovy
index 7bfc06120a..0c9d5de753 100644
--- a/regression-test/suites/nereids_p0/delete/delete_mow_partial_update.groovy
+++ b/regression-test/suites/nereids_p0/delete/delete_mow_partial_update.groovy
@@ -20,6 +20,8 @@ suite('nereids_delete_mow_partial_update') {
     sql 'set enable_fallback_to_original_planner=false'
     sql "set experimental_enable_nereids_planner=true;"
     sql 'set enable_nereids_dml=true'
+    
+    sql "sync"
 
     def tableName1 = "nereids_delete_mow_partial_update1"
     sql "DROP TABLE IF EXISTS ${tableName1};"
@@ -55,16 +57,19 @@ suite('nereids_delete_mow_partial_update') {
     // when using parital update insert stmt for delete stmt, it will use 
delete bitmap or delete sign rather than 
     // delete predicate to "delete" the rows
     sql "set skip_delete_predicate=true;"
+    sql "sync"
     qt_sql_skip_delete_predicate "select * from ${tableName1} order by uid;"
 
     sql "set skip_delete_sign=true;"
     sql "set skip_storage_engine_merge=true;"
     sql "set skip_delete_bitmap=true;"
+    sql "sync"
     qt_sql "select uid,v1,__DORIS_DELETE_SIGN__ from ${tableName1} order by 
uid,v1,__DORIS_DELETE_SIGN__;"
 
     sql "set skip_delete_sign=false;"
     sql "set skip_storage_engine_merge=false;"
     sql "set skip_delete_bitmap=false;"
+    sql "sync"
     def tableName3 = "test_partial_update_delete3"
     sql "DROP TABLE IF EXISTS ${tableName3};"
     sql """ CREATE TABLE IF NOT EXISTS ${tableName3} (
@@ -94,9 +99,11 @@ suite('nereids_delete_mow_partial_update') {
         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;"
     sql "set skip_delete_bitmap=true;"
+    sql "sync"
     qt_sql "select k1,c1,c2,c3,c4,__DORIS_DELETE_SIGN__ from ${tableName3} 
order by k1,c1,c2,c3,c4,__DORIS_DELETE_SIGN__;"
 }


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