This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new c2e7b19a12b [branch-2.0](regression) fix test stream load properties
fail (#28681)
c2e7b19a12b is described below
commit c2e7b19a12b7d6e3be0ae60bdb7048eb85a365d8
Author: HHoflittlefish777 <77738092+hhoflittlefish...@users.noreply.github.com>
AuthorDate: Thu Dec 21 10:38:02 2023 +0800
[branch-2.0](regression) fix test stream load properties fail (#28681)
---
.../stream_load/test_stream_load_properties.groovy | 15 +++++++++++++++
1 file changed, 15 insertions(+)
diff --git
a/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
b/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
index 63c23bdf17e..2666b5ad1a7 100644
---
a/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
+++
b/regression-test/suites/load_p0/stream_load/test_stream_load_properties.groovy
@@ -201,6 +201,7 @@ suite("test_stream_load_properties", "p0") {
assertEquals(0, json.NumberUnselectedRows)
}
}
+ sql "sync"
def tableName1 = "stream_load_" + tableName
if (i <= 3) {
qt_sql_timezone_shanghai "select * from ${tableName1} order by
k00,k01"
@@ -242,6 +243,7 @@ suite("test_stream_load_properties", "p0") {
assertEquals(0, json.NumberUnselectedRows)
}
}
+ sql "sync"
def tableName1 = "stream_load_" + tableName
if (i <= 3) {
qt_sql_timezone_Abidjan "select * from ${tableName1} order by
k00,k01"
@@ -286,6 +288,7 @@ suite("test_stream_load_properties", "p0") {
assertEquals(0, json.NumberUnselectedRows)
}
}
+ sql "sync"
def tableName1 = "stream_load_" + tableName
if (i <= 3) {
qt_sql_strict_mode "select * from ${tableName1} order by
k00,k01"
@@ -329,6 +332,7 @@ suite("test_stream_load_properties", "p0") {
assertEquals(0, json.NumberUnselectedRows)
}
}
+ sql "sync"
def tableName1 = "stream_load_" + tableName
if (i <= 3) {
qt_sql_max_filter_ratio "select * from ${tableName1} order by
k00,k01"
@@ -400,6 +404,7 @@ suite("test_stream_load_properties", "p0") {
assertEquals(0, json.NumberUnselectedRows)
}
}
+ sql "sync"
qt_sql_squence "select * from stream_load_uniq_tbl_basic_sequence
order by k00,k01"
} finally {
sql new
File("""${context.file.parent}/ddl/uniq_tbl_basic_drop_sequence.sql""").text
@@ -432,6 +437,7 @@ suite("test_stream_load_properties", "p0") {
assertEquals(0, json.NumberUnselectedRows)
}
}
+ sql "sync"
streamLoad {
table "stream_load_" + tableName
@@ -454,6 +460,7 @@ suite("test_stream_load_properties", "p0") {
assertEquals(0, json.NumberUnselectedRows)
}
}
+ sql "sync"
def tableName1 = "stream_load_" + tableName
qt_sql_merge_type "select * from ${tableName1} order by k00,k01"
} finally {
@@ -532,6 +539,7 @@ suite("test_stream_load_properties", "p0") {
assertEquals(0, json.NumberUnselectedRows)
}
}
+ sql "sync"
def tableName1 = "stream_load_" + tableName
if (i <= 3) {
@@ -541,6 +549,7 @@ suite("test_stream_load_properties", "p0") {
}
do_streamload_2pc.call(txnId, "abort", tableName1)
+ sql "sync"
if (i <= 3) {
qt_sql_2pc_abort "select * from ${tableName1} order by k00,k01"
@@ -570,8 +579,10 @@ suite("test_stream_load_properties", "p0") {
assertEquals(0, json.NumberUnselectedRows)
}
}
+ sql "sync"
do_streamload_2pc.call(txnId, "commit", tableName1)
+ sql "sync"
def count = 0
while (true) {
@@ -686,6 +697,7 @@ suite("test_stream_load_properties", "p0") {
assertEquals(0, json.NumberUnselectedRows)
}
}
+ sql "sync"
def tableName1 = "stream_load_" + tableName
if (i <= 3) {
qt_sql_skip_lines "select * from ${tableName1} order by
k00,k01"
@@ -805,6 +817,7 @@ suite("test_stream_load_properties", "p0") {
assertEquals(0, json.NumberUnselectedRows)
}
}
+ sql "sync"
def tableName1 = "stream_load_" + tableName
if (i <= 3) {
qt_sql_json_strip_outer_array "select * from ${tableName1}
order by k00,k01"
@@ -851,6 +864,7 @@ suite("test_stream_load_properties", "p0") {
assertEquals(0, json.NumberUnselectedRows)
}
}
+ sql "sync"
def tableName1 = "stream_load_" + tableName
if (i <= 3) {
qt_sql_json_jsonpath "select * from ${tableName1} order by
k00,k01"
@@ -896,6 +910,7 @@ suite("test_stream_load_properties", "p0") {
assertEquals(0, json.NumberUnselectedRows)
}
}
+ sql "sync"
def tableName1 = "stream_load_" + tableName
if (i <= 3) {
qt_sql_json_read_by_line "select * from ${tableName1} order by
k00,k01"
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
