diff --git a/regression-test/data/insert_p0/insert_group_commit_into_unique.out b/regression-test/data/insert_p0/insert_group_commit_into_unique.out index 17121bfe0b..b672c6f4cd 100644 --- a/regression-test/data/insert_p0/insert_group_commit_into_unique.out +++ b/regression-test/data/insert_p0/insert_group_commit_into_unique.out @@ -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 diff --git a/regression-test/data/insert_p0/insert_group_commit_into_unique_sync_mode.out b/regression-test/data/insert_p0/insert_group_commit_into_unique_sync_mode.out index 17121bfe0b..b672c6f4cd 100644 --- a/regression-test/data/insert_p0/insert_group_commit_into_unique_sync_mode.out +++ b/regression-test/data/insert_p0/insert_group_commit_into_unique_sync_mode.out @@ -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 diff --git a/regression-test/data/insert_p0/test_group_commit_2.csv b/regression-test/data/insert_p0/test_group_commit_2.csv index d706739913..c5c9eaa0e6 100644 --- a/regression-test/data/insert_p0/test_group_commit_2.csv +++ b/regression-test/data/insert_p0/test_group_commit_2.csv @@ -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 \ No newline at end of file diff --git a/regression-test/suites/insert_p0/insert_group_commit_into_unique.groovy b/regression-test/suites/insert_p0/insert_group_commit_into_unique.groovy index fba2473dfe..83247d2512 100644 --- a/regression-test/suites/insert_p0/insert_group_commit_into_unique.groovy +++ b/regression-test/suites/insert_p0/insert_group_commit_into_unique.groovy @@ -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 """ diff --git a/regression-test/suites/insert_p0/insert_group_commit_into_unique_sync_mode.groovy b/regression-test/suites/insert_p0/insert_group_commit_into_unique_sync_mode.groovy index 0d727b9ec4..aae859c71d 100644 --- a/regression-test/suites/insert_p0/insert_group_commit_into_unique_sync_mode.groovy +++ b/regression-test/suites/insert_p0/insert_group_commit_into_unique_sync_mode.groovy @@ -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 """