database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](regression) insert_group_commit_into_unique is unstable when cluster has multi BE (#31188)

Browse Source
This commit is contained in:
meiyi
2024-02-21 18:09:13 +08:00
committed by yiguolei
parent 29ae497871
commit ca89ac0c23
5 changed files with 62 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
regression-test/data/insert_p0/insert_group_commit_into_unique.out
View File

@ -6,13 +6,15 @@
4 \N -1 0
5 q 50 0
6 \N -1 0
11 a 211 0
12 b 23 1
11 a 21 0
12 b 22 0
13 c 23 0
14 d 24 0
15 c 23 0
16 d 24 1
27 e 25 0
110 a 211 0
120 b 23 1
-- !sql --
2 b -1 0
@ -20,11 +22,13 @@
4 \N -1 0
5 q 50 0
6 \N -1 0
11 a 211 0
11 a 21 0
12 b 22 0
13 c 23 0
14 d 24 0
15 c 23 0
27 e 25 0
110 a 211 0
-- !sql --
1 a 10 10 1
@ -33,13 +37,15 @@
4 \N 70 70 0
5 q 50 50 0
6 \N 60 60 0
11 a 211 211 0
12 b 23 23 1
11 a 21 21 0
12 b 22 22 0
13 c 23 23 0
14 d 24 24 0
15 c 23 23 0
16 d 24 24 1
27 e 25 25 0
110 a 211 211 0
120 b 23 23 1
-- !sql --
2 b 30 30 0
@ -47,11 +53,13 @@
4 \N 70 70 0
5 q 50 50 0
6 \N 60 60 0
11 a 211 211 0
11 a 21 21 0
12 b 22 22 0
13 c 23 23 0
14 d 24 24 0
15 c 23 23 0
27 e 25 25 0
110 a 211 211 0
-- !sql --
1 a 200 200 1
@ -86,13 +94,15 @@
4 \N -1 0
5 q 50 0
6 \N -1 0
11 a 211 0
12 b 23 1
11 a 21 0
12 b 22 0
13 c 23 0
14 d 24 0
15 c 23 0
16 d 24 1
27 e 25 0
110 a 211 0
120 b 23 1
-- !sql --
2 b -1 0
@ -100,11 +110,13 @@
4 \N -1 0
5 q 50 0
6 \N -1 0
11 a 211 0
11 a 21 0
12 b 22 0
13 c 23 0
14 d 24 0
15 c 23 0
27 e 25 0
110 a 211 0
-- !sql --
1 a 10 10 1
@ -113,13 +125,15 @@
4 \N 70 70 0
5 q 50 50 0
6 \N 60 60 0
11 a 211 211 0
12 b 23 23 1
11 a 21 21 0
12 b 22 22 0
13 c 23 23 0
14 d 24 24 0
15 c 23 23 0
16 d 24 24 1
27 e 25 25 0
110 a 211 211 0
120 b 23 23 1
-- !sql --
2 b 30 30 0
@ -127,11 +141,13 @@
4 \N 70 70 0
5 q 50 50 0
6 \N 60 60 0
11 a 211 211 0
11 a 21 21 0
12 b 22 22 0
13 c 23 23 0
14 d 24 24 0
15 c 23 23 0
27 e 25 25 0
110 a 211 211 0
-- !sql --
1 a 200 200 1

40
regression-test/data/insert_p0/insert_group_commit_into_unique_sync_mode.out
View File

@ -6,13 +6,15 @@
4 \N -1 0
5 q 50 0
6 \N -1 0
11 a 211 0
12 b 23 1
11 a 21 0
12 b 22 0
13 c 23 0
14 d 24 0
15 c 23 0
16 d 24 1
27 e 25 0
110 a 211 0
120 b 23 1
-- !sql --
2 b -1 0
@ -20,11 +22,13 @@
4 \N -1 0
5 q 50 0
6 \N -1 0
11 a 211 0
11 a 21 0
12 b 22 0
13 c 23 0
14 d 24 0
15 c 23 0
27 e 25 0
110 a 211 0
-- !sql --
1 a 10 10 1
@ -33,13 +37,15 @@
4 \N 70 70 0
5 q 50 50 0
6 \N 60 60 0
11 a 211 211 0
12 b 23 23 1
11 a 21 21 0
12 b 22 22 0
13 c 23 23 0
14 d 24 24 0
15 c 23 23 0
16 d 24 24 1
27 e 25 25 0
110 a 211 211 0
120 b 23 23 1
-- !sql --
2 b 30 30 0
@ -47,11 +53,13 @@
4 \N 70 70 0
5 q 50 50 0
6 \N 60 60 0
11 a 211 211 0
11 a 21 21 0
12 b 22 22 0
13 c 23 23 0
14 d 24 24 0
15 c 23 23 0
27 e 25 25 0
110 a 211 211 0
-- !sql --
1 a 200 200 1
@ -86,13 +94,15 @@
4 \N -1 0
5 q 50 0
6 \N -1 0
11 a 211 0
12 b 23 1
11 a 21 0
12 b 22 0
13 c 23 0
14 d 24 0
15 c 23 0
16 d 24 1
27 e 25 0
110 a 211 0
120 b 23 1
-- !sql --
2 b -1 0
@ -100,11 +110,13 @@
4 \N -1 0
5 q 50 0
6 \N -1 0
11 a 211 0
11 a 21 0
12 b 22 0
13 c 23 0
14 d 24 0
15 c 23 0
27 e 25 0
110 a 211 0
-- !sql --
1 a 10 10 1
@ -113,13 +125,15 @@
4 \N 70 70 0
5 q 50 50 0
6 \N 60 60 0
11 a 211 211 0
12 b 23 23 1
11 a 21 21 0
12 b 22 22 0
13 c 23 23 0
14 d 24 24 0
15 c 23 23 0
16 d 24 24 1
27 e 25 25 0
110 a 211 211 0
120 b 23 23 1
-- !sql --
2 b 30 30 0
@ -127,11 +141,13 @@
4 \N 70 70 0
5 q 50 50 0
6 \N 60 60 0
11 a 211 211 0
11 a 21 21 0
12 b 22 22 0
13 c 23 23 0
14 d 24 24 0
15 c 23 23 0
27 e 25 25 0
110 a 211 211 0
-- !sql --
1 a 200 200 1

4
regression-test/data/insert_p0/test_group_commit_2.csv
View File

@ -1,5 +1,5 @@
11,a,211,0
12,b,23,1
110,a,211,0
120,b,23,1
15,c,23,0
16,d,24,1
27,e,25,0
1 11 110 a 211 0
2 12 120 b 23 1
3 15 15 c 23 0
4 16 16 d 24 1
5 27 27 e 25 0

4
regression-test/suites/insert_p0/insert_group_commit_into_unique.groovy
View File

@ -146,7 +146,7 @@ suite("insert_group_commit_into_unique") {
checkStreamLoadResult(exception, result, 5, 5, 0, 0)
}
}
getRowCount(10)
getRowCount(12)
sql """ set show_hidden_columns = true """
qt_sql """ select id, name, score, __DORIS_DELETE_SIGN__ from ${dbTableName} order by id, name, score asc; """
sql """ set show_hidden_columns = false """
@ -232,7 +232,7 @@ suite("insert_group_commit_into_unique") {
checkStreamLoadResult(exception, result, 5, 5, 0, 0)
}
}
getRowCount(10)
getRowCount(12)
sql """ set show_hidden_columns = true """
qt_sql """ select id, name, score, __DORIS_SEQUENCE_COL__, __DORIS_DELETE_SIGN__ from ${dbTableName} order by id, name, score asc; """
sql """ set show_hidden_columns = false """

4
regression-test/suites/insert_p0/insert_group_commit_into_unique_sync_mode.groovy
View File

@ -185,7 +185,7 @@ suite("insert_group_commit_into_unique_sync_mode") {
checkStreamLoadResult(exception, result, 5, 5, 0, 0)
}
}
getRowCount(10)
getRowCount(12)
sql """ set show_hidden_columns = true """
qt_sql """ select id, name, score, __DORIS_DELETE_SIGN__ from ${dbTableName} order by id, name, score asc; """
sql """ set show_hidden_columns = false """
@ -275,7 +275,7 @@ suite("insert_group_commit_into_unique_sync_mode") {
checkOffModeStreamLoadResult(exception, result, 5, 5, 0, 0)
}
}
getRowCount(10)
getRowCount(12)
sql """ set show_hidden_columns = true """
qt_sql """ select id, name, score, __DORIS_SEQUENCE_COL__, __DORIS_DELETE_SIGN__ from ${dbTableName} order by id, name, score asc; """
sql """ set show_hidden_columns = false """