This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 c4cc6cefda9 [fix](regression-test) fix http stream 2pc case(#25507)
c4cc6cefda9 is described below
commit c4cc6cefda9c00895a98b42bb84a306b49278b12
Author: HHoflittlefish777 <77738092+hhoflittlefish...@users.noreply.github.com>
AuthorDate: Tue Oct 17 13:21:03 2023 +0800
[fix](regression-test) fix http stream 2pc case(#25507)
---
.../load_p0/http_stream/test_http_stream_2pc.groovy | 15 +++++++++++++++
1 file changed, 15 insertions(+)
diff --git
a/regression-test/suites/load_p0/http_stream/test_http_stream_2pc.groovy
b/regression-test/suites/load_p0/http_stream/test_http_stream_2pc.groovy
index 86466ba2726..b05ce6c42b8 100644
--- a/regression-test/suites/load_p0/http_stream/test_http_stream_2pc.groovy
+++ b/regression-test/suites/load_p0/http_stream/test_http_stream_2pc.groovy
@@ -72,6 +72,21 @@ suite("test_http_stream_2pc", "p0") {
assertEquals(code, 0)
assertEquals("success", json2pc.status.toLowerCase())
+ def count = 0
+ while (true) {
+ res = sql "select count(*) from ${tableName1}"
+ if (res[0][0] > 0) {
+ break
+ }
+ if (count >= 60) {
+ log.error("stream load commit can not visible for long time")
+ assertEquals(2, res[0][0])
+ break
+ }
+ sleep(1000)
+ count++
+ }
+
qt_sql "select id, name from ${tableName1} order by id"
} finally {
try_sql "DROP TABLE IF EXISTS ${tableName1}"
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
