This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 81b1ad179b9 branch-3.0: [fix](test) fix test_routine_load_eof case
execute too long #47663 (#47667)
81b1ad179b9 is described below
commit 81b1ad179b9624a6a89879b2e1ca528bd03c335d
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Feb 10 13:56:54 2025 +0800
branch-3.0: [fix](test) fix test_routine_load_eof case execute too long
#47663 (#47667)
Cherry-picked from #47663
Co-authored-by: hui lai <[email protected]>
---
.../suites/load_p0/routine_load/test_routine_load_eof.groovy | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/regression-test/suites/load_p0/routine_load/test_routine_load_eof.groovy
b/regression-test/suites/load_p0/routine_load/test_routine_load_eof.groovy
index 5e61a3ec1d0..d4078896068 100644
--- a/regression-test/suites/load_p0/routine_load/test_routine_load_eof.groovy
+++ b/regression-test/suites/load_p0/routine_load/test_routine_load_eof.groovy
@@ -40,6 +40,7 @@ suite("test_routine_load_eof","p0") {
// Create kafka producer
def producer = new KafkaProducer<>(props)
+ def count = 0
while(true) {
Thread.sleep(1000)
for (String kafkaCsvTopic in kafkaCsvTpoics) {
@@ -51,6 +52,10 @@ suite("test_routine_load_eof","p0") {
producer.send(record)
}
}
+ if (count >= 120) {
+ break
+ }
+ count++
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
