This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch routineload_flexible_update
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/routineload_flexible_update by
this push:
new adb92cd243c fix: Fix wait condition in Test 1 for flexible partial
update
adb92cd243c is described below
commit adb92cd243c8f964329323fdd1fc73b8fd6360cb
Author: Yongqiang YANG <[email protected]>
AuthorDate: Fri Jan 16 09:53:18 2026 -0800
fix: Fix wait condition in Test 1 for flexible partial update
The waitForTaskFinish function waits until rowCount > expectedMinRows.
Test 1 has 5 initial rows and expects 6 rows after processing (3 updates
+ 1 insert). The wait condition was set to 4, which meant `5 > 4` was
immediately true and the test didn't wait for Kafka messages to be
consumed.
Changed expectedMinRows from 4 to 5 so the test properly waits for
at least 6 rows.
Co-Authored-By: Claude Opus 4.5 <[email protected]>
---
.../routine_load/test_routine_load_flexible_partial_update.groovy | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/regression-test/suites/load_p0/routine_load/test_routine_load_flexible_partial_update.groovy
b/regression-test/suites/load_p0/routine_load/test_routine_load_flexible_partial_update.groovy
index 12758ab366e..9211598f6bd 100644
---
a/regression-test/suites/load_p0/routine_load/test_routine_load_flexible_partial_update.groovy
+++
b/regression-test/suites/load_p0/routine_load/test_routine_load_flexible_partial_update.groovy
@@ -104,7 +104,9 @@ suite("test_routine_load_flexible_partial_update",
"nonConcurrent") {
producer.flush()
// wait for routine load task to finish
- RoutineLoadTestUtils.waitForTaskFinish(runSql, job1, tableName1, 4)
+ // Initial: 5 rows, Kafka: 4 messages (3 updates + 1 insert),
Expected: 6 rows
+ // waitForTaskFinish waits until rowCount > expectedMinRows, so
pass 5
+ RoutineLoadTestUtils.waitForTaskFinish(runSql, job1, tableName1, 5)
// verify flexible partial update results
qt_select_after_flex_update1 "SELECT id, name, score, age FROM
${tableName1} ORDER BY id"
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
