This is an automated email from the ASF dual-hosted git repository.

englefly 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 f77c69ab95 [fix](test) case bug, streamload without sync. (#21161)
f77c69ab95 is described below

commit f77c69ab958cfdeec95f121345199bbed8692c41
Author: shuke <[email protected]>
AuthorDate: Wed Jun 28 18:22:19 2023 +0800

    [fix](test) case bug, streamload without sync. (#21161)
---
 regression-test/suites/datatype_p0/decimalv3/test_load.groovy         | 4 +++-
 regression-test/suites/github_events_p2/load.groovy                   | 1 +
 .../suites/load_p0/stream_load/test_map_load_and_compaction.groovy    | 2 ++
 .../suites/query_p0/aggregate/push_filter_through_agg.groovy          | 3 ++-
 4 files changed, 8 insertions(+), 2 deletions(-)

diff --git a/regression-test/suites/datatype_p0/decimalv3/test_load.groovy 
b/regression-test/suites/datatype_p0/decimalv3/test_load.groovy
index ba7b04ad94..c2651b3c90 100644
--- a/regression-test/suites/datatype_p0/decimalv3/test_load.groovy
+++ b/regression-test/suites/datatype_p0/decimalv3/test_load.groovy
@@ -42,7 +42,7 @@ suite("test_load") {
         """
 
         StringBuilder commandBuilder = new StringBuilder()
-        commandBuilder.append("""curl --location-trusted -u 
${context.config.feHttpUser}:${context.config.feHttpPassword}""")
+        commandBuilder.append("""curl --max-time 5 --location-trusted -u 
${context.config.feHttpUser}:${context.config.feHttpPassword}""")
         commandBuilder.append(""" -H format:csv -T 
${context.file.parent}/test_data/test.csv 
http://${context.config.feHttpAddress}/api/"""; + dbName + "/" + tableName + 
"/_stream_load")
         command = commandBuilder.toString()
         process = command.execute()
@@ -51,6 +51,8 @@ suite("test_load") {
         out = process.getText()
         logger.info("Run command: command=" + command + ",code=" + code + ", 
out=" + out + ", err=" + err)
         assertEquals(code, 0)
+
+        sql """sync"""
         qt_select_default """ SELECT * FROM ${tableName} t ORDER BY a; """
     } finally {
         try_sql("DROP TABLE IF EXISTS ${tableName}")
diff --git a/regression-test/suites/github_events_p2/load.groovy 
b/regression-test/suites/github_events_p2/load.groovy
index c2007aeb62..46803f3289 100644
--- a/regression-test/suites/github_events_p2/load.groovy
+++ b/regression-test/suites/github_events_p2/load.groovy
@@ -39,6 +39,7 @@ suite("load") {
         timeout 72000
     }
     sql "sync"
+    sql """ ANALYZE TABLE github_events WITH SYNC """;
     qt_sql_select_count """ select count(*) from github_events; """
 }
 /**
diff --git 
a/regression-test/suites/load_p0/stream_load/test_map_load_and_compaction.groovy
 
b/regression-test/suites/load_p0/stream_load/test_map_load_and_compaction.groovy
index 1c08af4864..ebcbd4ba79 100644
--- 
a/regression-test/suites/load_p0/stream_load/test_map_load_and_compaction.groovy
+++ 
b/regression-test/suites/load_p0/stream_load/test_map_load_and_compaction.groovy
@@ -90,6 +90,8 @@ suite("test_map_load_and_compaction", "p0") {
         for (int i = 0; i < 5; ++i) {
             streamLoadJson.call(4063, dataFile1)
         }
+        
+        sql """sync"""
 
         // check result
         qt_select "SELECT count(*) FROM ${testTable};"
diff --git 
a/regression-test/suites/query_p0/aggregate/push_filter_through_agg.groovy 
b/regression-test/suites/query_p0/aggregate/push_filter_through_agg.groovy
index 82ee73c4f2..7987c98c2a 100644
--- a/regression-test/suites/query_p0/aggregate/push_filter_through_agg.groovy
+++ b/regression-test/suites/query_p0/aggregate/push_filter_through_agg.groovy
@@ -16,6 +16,7 @@
 // under the License.
 
 suite("push_filter_through_agg") {
+    sql """DROP TABLE IF EXISTS t_push_filter_through_agg"""
     sql """
         CREATE TABLE t_push_filter_through_agg (col1 varchar(11451) not null, 
col2 int not null, col3 int not null)
         UNIQUE KEY(col1)
@@ -56,4 +57,4 @@ suite("push_filter_through_agg") {
      qt_sql """
          SELECT SUM(`col2`) FROM view_i WHERE `col1` BETWEEN 10 AND 20 LIMIT 1;
      """
-}
\ No newline at end of file
+}


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to