You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by kx...@apache.org on 2023/08/05 01:17:01 UTC
[doris] 01/03: [case](fix) add sync after stream load (#22601)
This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
commit ea9030ad778bdfd1793780909a65625c987b1b38
Author: Dongyang Li <he...@qq.com>
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 ++-
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 +
6 files changed, 8 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/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 4022bb6d98..f8ed38c96f 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
@@ -90,6 +90,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: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org