This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new ef0e0b7d79 [case](fix) add sync after stream load (#22601)
ef0e0b7d79 is described below
commit ef0e0b7d79c855fe1b65d1cd2944c6b50d2f40bb
Author: Dongyang Li <[email protected]>
AuthorDate: Sat Aug 5 08:28:26 2023 +0800
[case](fix) add sync after stream load (#22601)
---
regression-test/suites/load_p0/stream_load/test_json_load.groovy | 3 ++-
.../partition_p0/list_partition/test_list_partition_datatype.groovy | 1 +
regression-test/suites/partition_p0/test_partition_operation.groovy | 1 +
.../unique_with_mow_p0/partial_update/test_partial_update.groovy | 2 +-
.../partial_update/test_partial_update_delete.groovy | 1 +
.../partial_update/test_partial_update_parallel.groovy | 2 ++
.../partial_update/test_partial_update_upsert.groovy | 1 +
7 files changed, 9 insertions(+), 2 deletions(-)
diff --git a/regression-test/suites/load_p0/stream_load/test_json_load.groovy
b/regression-test/suites/load_p0/stream_load/test_json_load.groovy
index c982196bb1..539eafe6ed 100644
--- a/regression-test/suites/load_p0/stream_load/test_json_load.groovy
+++ b/regression-test/suites/load_p0/stream_load/test_json_load.groovy
@@ -606,9 +606,10 @@ suite("test_json_load", "p0") {
"replication_num" = "1"
);
"""
-1
+
load_json_data.call("${testTable}", 'with_jsonpath', '', 'true',
'json', """productid, deviceid, data, datatimestamp,
dt=from_unixtime(substr(datatimestamp,1,10),'%Y%m%d')""",
'["$.productid","$.deviceid","$.data","$.data.datatimestamp"]', '', '', '',
'with_jsonpath.json')
+ sql "sync"
qt_select22 "select * from ${testTable}"
} finally {
diff --git
a/regression-test/suites/partition_p0/list_partition/test_list_partition_datatype.groovy
b/regression-test/suites/partition_p0/list_partition/test_list_partition_datatype.groovy
index b532d9de20..1a667533dd 100644
---
a/regression-test/suites/partition_p0/list_partition/test_list_partition_datatype.groovy
+++
b/regression-test/suites/partition_p0/list_partition/test_list_partition_datatype.groovy
@@ -74,6 +74,7 @@ suite("test_list_partition_datatype", "p0") {
assertEquals(15, json.NumberLoadedRows)
}
}
+ sql """sync"""
test {
sql "SELECT * FROM ${tableName} ORDER BY k1, k2"
resultFile "expect_baseall.out"
diff --git
a/regression-test/suites/partition_p0/test_partition_operation.groovy
b/regression-test/suites/partition_p0/test_partition_operation.groovy
index eae7f5fa38..05842a6532 100644
--- a/regression-test/suites/partition_p0/test_partition_operation.groovy
+++ b/regression-test/suites/partition_p0/test_partition_operation.groovy
@@ -44,6 +44,7 @@ suite("test_partition_operation", "p1") {
set "column_separator", ","
file "./multi_partition/partition_table.csv"
}
+ sql """sync"""
test {
sql "select * from ${tableName} order by k1, k2"
resultFile "./multi_partition/partition_table.out"
diff --git
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update.groovy
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update.groovy
index e8538abd88..b8052cf525 100644
---
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update.groovy
+++
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update.groovy
@@ -172,7 +172,7 @@ suite("test_primary_key_partial_update", "p0") {
assertEquals(2, json.NumberFilteredRows)
}
}
-
+ sql "sync"
qt_partial_update_in_one_stream_load """
select * from ${tableName} order by id;
"""
diff --git
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_delete.groovy
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_delete.groovy
index c1fb7f7b99..e582414f4f 100644
---
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_delete.groovy
+++
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_delete.groovy
@@ -92,6 +92,7 @@ suite('test_partial_update_delete') {
file 'partial_update_delete.csv'
time 10000
}
+ sql "sync"
qt_sql "select k1,c1,c2,c3,c4 from ${tableName3} order by k1,c1,c2,c3,c4;"
sql "set skip_delete_sign=true;"
sql "set skip_storage_engine_merge=true;"
diff --git
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_parallel.groovy
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_parallel.groovy
index a6e15107e4..8875a5d6d4 100644
---
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_parallel.groovy
+++
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_parallel.groovy
@@ -82,6 +82,8 @@ suite("test_primary_key_partial_update_parallel", "p0") {
}
}
+ sql "sync"
+
sql """
select * from ${tableName} order by id;
"""
diff --git
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_upsert.groovy
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_upsert.groovy
index 34d3c82d72..3c02ee3bb6 100644
---
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_upsert.groovy
+++
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_upsert.groovy
@@ -99,5 +99,6 @@ suite("test_partial_update_upsert", "p0") {
assertEquals("fail", json.Status.toLowerCase())
}
}
+ sql "sync"
sql """ DROP TABLE IF EXISTS ${tableName2} """
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
