From ef0e0b7d79c855fe1b65d1cd2944c6b50d2f40bb Mon Sep 17 00:00:00 2001 From: Dongyang Li Date: Sat, 5 Aug 2023 08:28:26 +0800 Subject: [PATCH] [case](fix) add sync after stream load (#22601) --- .../suites/load_p0/stream_load/test_json_load.groovy | 3 ++- .../list_partition/test_list_partition_datatype.groovy | 1 + .../suites/partition_p0/test_partition_operation.groovy | 1 + .../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} """ }