[fix](test) add sync for some cases and adjust data path for tpch_unique_sql_zstd_p0 (#13102)

regression-test/suites/load_p0/stream_load/load_json_with_jsonpath.groovy

@@ -86,6 +86,7 @@ suite("test_load_json_with_jsonpath", "p0") {
         load_array_data.call(testTable, 'true', '', 'json', '', '["$.k1", "$.v1"]', '', '', '', '', 'test_load_with_jsonpath.json')
 
         // select the table and check whether the data is correct
+        sql "sync"
         qt_select "select * from ${testTable} order by k1"
 
     } finally {
@@ -100,6 +101,7 @@ suite("test_load_json_with_jsonpath", "p0") {
 
         load_array_data.call(testTable, 'true', '', 'json', '', '["$.k1", "$.v1"]', '', '', '', '', 'test_load_with_jsonpath.json')
 
+        sql "sync"
         // select the table and check whether the data is correct
         qt_select "select * from ${testTable} order by k1"
 

regression-test/suites/load_p0/stream_load/test_json_load.groovy

@@ -162,6 +162,7 @@ suite("test_json_load", "p0") {
         while(max_try_milli_secs) {
             result = sql "show load where label = '${checklabel}'"
             if(result[0][2] == "FINISHED") {
+                sql "sync"
                 qt_select "select * from ${testTablex} order by id"
                 break
             } else {
@@ -182,6 +183,7 @@ suite("test_json_load", "p0") {
 
         load_json_data.call('true', '', 'json', '', '', '', '', '', 'simple_json.json')
 
+        sql "sync"
         qt_select "select * from ${testTable} order by id"
 
     } finally {
@@ -196,6 +198,7 @@ suite("test_json_load", "p0") {
 
         load_json_data.call('true', '', 'json', 'id= id * 10', '', '', '', '', 'simple_json.json')
 
+        sql "sync" 
         qt_select "select * from ${testTable} order by id"
 
     } finally {
@@ -211,6 +214,7 @@ suite("test_json_load", "p0") {
         load_json_data.call('true', '', 'json', '', '[\"$.id\", \"$.code\"]',
                             '', '', '', 'simple_json.json')
 
+        sql "sync"
         qt_select "select * from ${testTable} order by id"
 
     } finally {
@@ -226,6 +230,7 @@ suite("test_json_load", "p0") {
         load_json_data.call('true', '', 'json', 'code = id * 10 + 200', '[\"$.id\"]',
                             '', '', '', 'simple_json.json')
 
+        sql "sync"
         qt_select "select * from ${testTable} order by id"
 
     } finally {
@@ -241,6 +246,7 @@ suite("test_json_load", "p0") {
         load_json_data.call('true', 'true', 'json', '', '[\"$.id\", \"$.code\"]',
                             '', '', '', 'multi_line_json.json')
         
+        sql "sync"
         qt_select "select * from ${testTable} order by id"
 
     } finally {
@@ -256,6 +262,7 @@ suite("test_json_load", "p0") {
         load_json_data.call('true', 'true', 'json', 'id= id * 10', '[\"$.id\", \"$.code\"]',
                             '', '', '', 'multi_line_json.json')
 
+        sql "sync"
         qt_select "select * from ${testTable} order by id"
 
     } finally {
@@ -271,6 +278,7 @@ suite("test_json_load", "p0") {
         load_json_data.call('true', 'true', 'json', 'id= id * 10', '[\"$.id\", \"$.code\"]',
                             '', 'id > 50', '', 'multi_line_json.json')
 
+        sql "sync"
         qt_select "select * from ${testTable} order by id"
 
     } finally {
@@ -286,6 +294,7 @@ suite("test_json_load", "p0") {
         load_json_data.call('true', 'true', 'json', 'id= id * 10', '[\"$.id\", \"$.code\"]',
                             '', 'id > 50', 'true', 'multi_line_json.json')
 
+        sql "sync"
         qt_select "select * from ${testTable} order by id"
 
     } finally {
@@ -301,6 +310,7 @@ suite("test_json_load", "p0") {
         load_json_data.call('', 'true', 'json', 'id= id * 10', '',
                             '$.item', '', 'true', 'nest_json.json')
 
+        sql "sync"
         qt_select "select * from ${testTable} order by id"
 
     } finally {
@@ -315,6 +325,7 @@ suite("test_json_load", "p0") {
         load_json_data.call('', 'true', 'json', 'id= id * 10', '',
                             '$.item', '', 'true', 'invalid_json.json', true)
 
+        sql "sync"
         qt_select "select * from ${testTable} order by id"
 
     } finally {
@@ -368,6 +379,7 @@ suite("test_json_load", "p0") {
             load_json_data.call('true', '', 'json', '', '',
                     '', '', '', 'invalid_json_array.json', true)
 
+            sql "sync"
             qt_select "select * from ${testTable}"
 
         } finally {

regression-test/suites/tpcds_sf1_unique_p1/load.groovy

@@ -139,6 +139,7 @@ suite("load") {
     }
 
     // CREATE-TABLE-AS-SELECT
+    sql "drop table if exists t;"
     sql "create table t properties('replication_num'='1') as select * from item;"
     def origin_count = sql "select count(*) from item"
     def new_count = sql "select count(*) from t"

regression-test/suites/tpch_unique_sql_zstd_p0/load.groovy

@@ -54,7 +54,7 @@ suite("load") {
 
             // relate to ${DORIS_HOME}/regression-test/data/demo/streamload_input.csv.
             // also, you can stream load a http stream, e.g. http://xxx/some.csv
-            file """${context.sf1DataPath}/regression/tpch/sf0.1/${tableName}.tbl.gz"""
+            file """${getS3Url()}/regression/tpch/sf0.1/${tableName}.tbl.gz"""
 
             time 10000 // limit inflight 10s