Skip to content

Commit

Permalink
[fix](regression) fix flaky partial update cases (apache#42072)
Browse files Browse the repository at this point in the history
Add `sync` operation after streamload before query
  • Loading branch information
zhannngchen committed Nov 4, 2024
1 parent e43d255 commit 0de16c2
Showing 1 changed file with 7 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -64,6 +64,7 @@ suite("test_partial_update_merge_type", "p0") {
file 'merge1.csv'
time 10000
}
sql "sync"
qt_sql_1_1 """select * from ${tableName} order by k;"""
// 1.2 merge_type=MERGE, no sequence col, no value col
streamLoad {
Expand All @@ -77,6 +78,7 @@ suite("test_partial_update_merge_type", "p0") {
file 'merge5.csv'
time 10000
}
sql "sync"
qt_sql_1_2 """select * from ${tableName} order by k;"""
// 2.1 merge_type=DELETE, no sequence col
streamLoad {
Expand All @@ -101,6 +103,7 @@ suite("test_partial_update_merge_type", "p0") {
file 'merge6.csv'
time 10000
}
sql "sync"
qt_sql_2_2 """select * from ${tableName} order by k;"""


Expand Down Expand Up @@ -132,6 +135,7 @@ suite("test_partial_update_merge_type", "p0") {
file 'merge3.csv'
time 10000
}
sql "sync"
qt_sql_3_1 """select * from ${tableName} order by k;"""
inspect_rows """select k,c1,c2,c3,__DORIS_SEQUENCE_COL__,__DORIS_DELETE_SIGN__ from ${tableName} order by k,__DORIS_SEQUENCE_COL__;"""
// 3.2 merge_type=MERGE, has sequence type col, no value col
Expand All @@ -147,6 +151,7 @@ suite("test_partial_update_merge_type", "p0") {
file 'merge7.csv'
time 10000
}
sql "sync"
qt_sql_3_2 """select * from ${tableName} order by k;"""
inspect_rows """select k,c1,c2,c3,__DORIS_SEQUENCE_COL__,__DORIS_DELETE_SIGN__ from ${tableName} order by k,__DORIS_SEQUENCE_COL__;"""

Expand All @@ -162,6 +167,7 @@ suite("test_partial_update_merge_type", "p0") {
file 'merge4.csv'
time 10000
}
sql "sync"
qt_sql_4_1 """select * from ${tableName} order by k;"""
inspect_rows """select k,c1,c2,c3,__DORIS_SEQUENCE_COL__,__DORIS_DELETE_SIGN__ from ${tableName} order by k,__DORIS_SEQUENCE_COL__;"""
// 4.2 merge_type=DELETE, has sequence type col, no value col
Expand All @@ -176,6 +182,7 @@ suite("test_partial_update_merge_type", "p0") {
file 'merge8.csv'
time 10000
}
sql "sync"
qt_sql_4_2 """select * from ${tableName} order by k;"""
inspect_rows """select k,c1,c2,c3,__DORIS_SEQUENCE_COL__,__DORIS_DELETE_SIGN__ from ${tableName} order by k,__DORIS_SEQUENCE_COL__;"""

Expand Down

0 comments on commit 0de16c2

Please sign in to comment.