From b226b8751983c914014eb8097594f9b5bba8ec1c Mon Sep 17 00:00:00 2001
From: zhannngchen <48427519+zhannngchen@users.noreply.github.com>
Date: Sat, 2 Nov 2024 21:31:44 +0800
Subject: [PATCH] [fix](regression) fix flaky partial update cases (#42908)

## Proposed changes

Issue Number: close #xxx

#42072 missed a case
---
 .../partial_update/test_mix_partial_update.groovy     | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/regression-test/suites/unique_with_mow_p0/partial_update/test_mix_partial_update.groovy b/regression-test/suites/unique_with_mow_p0/partial_update/test_mix_partial_update.groovy
index 0a2322b9d0b8f6..35b5e0cce81177 100644
--- a/regression-test/suites/unique_with_mow_p0/partial_update/test_mix_partial_update.groovy
+++ b/regression-test/suites/unique_with_mow_p0/partial_update/test_mix_partial_update.groovy
@@ -119,6 +119,7 @@ suite('test_mix_partial_update') {
                 file "test_mix_partial_update_load1.csv"
                 time 10000 // limit inflight 10s
             }
+            sql "sync"
             // sql "insert into ${tableInsertName1} values(1,1,1,1,1),(1,1,1,1,10),(2,2,2,2,2),(3,3,3,3,3)"
             // 1,1,1,1,10
             // 2,2,2,2,2
@@ -134,6 +135,7 @@ suite('test_mix_partial_update') {
                 file "test_mix_partial_update_load2.csv"
                 time 10000 // limit inflight 10s
             }
+            sql "sync"
             //sql "insert into ${tableStreamName1} (k1,c1,c2,c3,seq,__DORIS_DELETE_SIGN__) values(1,10,null,10,10,1)"
             // 2,2,2,2,2
             // 3,3,3,3,3
@@ -149,6 +151,7 @@ suite('test_mix_partial_update') {
                 file "test_mix_partial_update_load3.csv"
                 time 10000 // limit inflight 10s
             }
+            sql "sync"
             //sql "insert into ${tableStreamName1} (k1,c1,c2,c3,seq,__DORIS_DELETE_SIGN__) values(1,10,null,10,20,1)"
             // 2,2,2,2,2
             // 3,3,3,3,3
@@ -164,6 +167,7 @@ suite('test_mix_partial_update') {
                 file "test_mix_partial_update_load4.csv"
                 time 10000 // limit inflight 10s
             }
+            sql "sync"
             //sql "insert into ${tableStreamName1} (k1,c1,c2,c3,seq,__DORIS_DELETE_SIGN__) values(1,10,null,10,1,0)"
             // 1,10,null,10,1
             // 2,2,2,2,2
@@ -184,6 +188,7 @@ suite('test_mix_partial_update') {
                 file "test_mix_partial_update_load5.csv"
                 time 10000 // limit inflight 10s
             }
+            sql "sync"
             //sql "set enable_unique_key_partial_update=true;"
             //sql "set enable_insert_strict=false;"
             //sql "insert into ${tableStreamName1} (k1,seq) values(2,1)"
@@ -200,6 +205,7 @@ suite('test_mix_partial_update') {
                 file "test_mix_partial_update_load6.csv"
                 time 10000 // limit inflight 10s
             }
+            sql "sync"
             //sql "set enable_unique_key_partial_update=true;"
             //sql "set enable_insert_strict=false;"
             // sql "insert into ${tableStreamName1} (k1,seq,__DORIS_DELETE_SIGN__) values(3,1,1)"
@@ -214,6 +220,7 @@ suite('test_mix_partial_update') {
                 file "test_mix_partial_update_load7.csv"
                 time 10000 // limit inflight 10s
             }
+            sql "sync"
             // sql "insert into ${tableStreamName1} values(4,4,4,4,4)"
             // 2,2,2,2,1
             // 3,3,3,3,3
@@ -316,6 +323,7 @@ suite('test_mix_partial_update') {
                 file "test_mix_partial_update_load_A.csv"
                 time 10000 // limit inflight 10s
             }
+            sql "sync"
             qt_select_A "select k1,c2,c3,c4 from ${tableStreamName2}"
             qt_select_AA "select count(distinct c1) from ${tableStreamName2}"
             qt_select_AAA "select count(*) from ${tableStreamName2} where c5 = c6"
@@ -330,6 +338,7 @@ suite('test_mix_partial_update') {
                 file "test_mix_partial_update_load_B.csv"
                 time 10000 // limit inflight 10s
             }
+            sql "sync"
             qt_select_B "select k1,c2,c3,c4 from ${tableStreamName2}"
             qt_select_BB "select count(distinct c1) from ${tableStreamName2}"
             qt_select_BBB "select count(*) from ${tableStreamName2} where c5 = c6"
@@ -354,6 +363,7 @@ suite('test_mix_partial_update') {
                 file "test_mix_partial_update_load_C.csv"
                 time 10000 // limit inflight 10s
             }
+            sql "sync"
             qt_select_D "select k1,c2,c3,c4 from ${tableStreamName2}"
             qt_select_DD "select count(distinct c1) from ${tableStreamName2}"
             qt_select_DDD "select count(*) from ${tableStreamName2} where c5 = c7"
@@ -373,6 +383,7 @@ suite('test_mix_partial_update') {
                 file "test_mix_partial_update_load_D.csv"
                 time 10000 // limit inflight 10s
             }
+            sql "sync"
             qt_select_E "select k1,c2,c3,c4 from ${tableStreamName2}"
             qt_select_EE "select count(distinct c1) from ${tableStreamName2}"
             qt_select_EEE "select count(*) from ${tableStreamName2} where c5 = c7"