You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2023/06/06 00:32:33 UTC
[doris] branch master updated: [fix](regression) add sync after streamload in test_stream_load (#20425)
This is an automated email from the ASF dual-hosted git repository.
yiguolei 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 6c96e1dc9f [fix](regression) add sync after streamload in test_stream_load (#20425)
6c96e1dc9f is described below
commit 6c96e1dc9f9335fa21e83f9e373d1d8704919ffa
Author: Kaijie Chen <ck...@apache.org>
AuthorDate: Tue Jun 6 08:32:25 2023 +0800
[fix](regression) add sync after streamload in test_stream_load (#20425)
Add sync after streamload in test_stream_load to fix following error:
Exception in load_p0/stream_load/test_stream_load.groovy(line 180):
throw exception
}
log.info("Stream load result: ${result}".toString())
def json = parseJson(result)
assertEquals("success", json.Status.toLowerCase())
assertEquals(1, json.NumberTotalRows)
assertEquals(0, json.NumberFilteredRows)
}
}
order_qt_sql1 " SELECT * FROM ${tableName2}"
^^^^^^^^^^^^^^^^^^^^^^^^^^ERROR LINE^^^^^^^^^^^^^^^^^^^^^^^^^^
// test common case
def tableName3 = "test_all"
def tableName4 = "test_less_col"
def tableName5 = "test_bitmap_and_hll"
def tableName6 = "test_unique_key"
def tableName7 = "test_unique_key_with_delete"
def tableName8 = "test_array"
def tableName10 = "test_struct"
sql """ DROP TABLE IF EXISTS ${tableName3} """
Exception:
java.lang.IllegalStateException: Check tag 'sql1' failed:
Check tag 'sql1' failed, line 1 mismatch, real line is empty, but expect is 2019 9 9 9 7.700 a 2019-09-09 1970-01-01T08:33:39 k7 9.0 9.0
sql:
SELECT * FROM load_nullable_to_not_nullable
---
regression-test/suites/load_p0/stream_load/test_stream_load.groovy | 3 +++
1 file changed, 3 insertions(+)
diff --git a/regression-test/suites/load_p0/stream_load/test_stream_load.groovy b/regression-test/suites/load_p0/stream_load/test_stream_load.groovy
index 351bab3afd..e481c1c541 100644
--- a/regression-test/suites/load_p0/stream_load/test_stream_load.groovy
+++ b/regression-test/suites/load_p0/stream_load/test_stream_load.groovy
@@ -89,6 +89,7 @@ suite("test_stream_load", "p0") {
}
}
+ sql "sync"
sql """ DROP TABLE IF EXISTS ${tableName} """
sql """
CREATE TABLE IF NOT EXISTS ${tableName} (
@@ -177,6 +178,7 @@ suite("test_stream_load", "p0") {
assertEquals(0, json.NumberFilteredRows)
}
}
+ sql "sync"
order_qt_sql1 " SELECT * FROM ${tableName2}"
// test common case
@@ -358,6 +360,7 @@ suite("test_stream_load", "p0") {
assertEquals(0, json.NumberLoadedRows)
}
}
+ sql "sync"
// load with skip 2 columns, with gzip
streamLoad {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org