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 c0ceb629c77ac019298c9489bd7311ca5a8796e3
Author: shuke <37901441+shuke...@users.noreply.github.com>
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 ++
 3 files changed, 6 insertions(+), 1 deletion(-)

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 879b519cf2..c5eb2689bd 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
@@ -89,6 +89,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};"


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to