This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new ffba1e5271f branch-3.1: [fix](test) fix test_routine_load_restart_fe
fail #53266 (#53301)
ffba1e5271f is described below
commit ffba1e5271fc09bd35430dc5bc8564f33a9dfd77
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Jul 15 19:54:14 2025 +0800
branch-3.1: [fix](test) fix test_routine_load_restart_fe fail #53266
(#53301)
Cherry-picked from #53266
Co-authored-by: hui lai <[email protected]>
---
.../test_routine_load_restart_fe.groovy | 51 +++++++++++-----------
1 file changed, 25 insertions(+), 26 deletions(-)
diff --git
a/regression-test/suites/load_p0/routine_load/test_routine_load_restart_fe.groovy
b/regression-test/suites/load_p0/routine_load/test_routine_load_restart_fe.groovy
index 5554978e500..104026fb16e 100644
---
a/regression-test/suites/load_p0/routine_load/test_routine_load_restart_fe.groovy
+++
b/regression-test/suites/load_p0/routine_load/test_routine_load_restart_fe.groovy
@@ -50,15 +50,14 @@ suite("test_routine_load_restart_fe", "docker") {
producer.send(record)
}
}
- }
- def options = new ClusterOptions()
- options.setFeNum(1)
- docker(options) {
- def load_with_injection = { injection ->
- def jobName = "test_routine_load_restart"
- def tableName = "dup_tbl_basic_multi_table"
- if (enabled != null && enabled.equalsIgnoreCase("true")) {
+ def options = new ClusterOptions()
+ options.setFeNum(1)
+ options.enableDebugPoints()
+ def jobName = "test_routine_load_restart"
+ def tableName = "dup_tbl_basic_multi_table"
+ docker(options) {
+ def load_with_injection = { injection ->
try {
GetDebugPoint().enableDebugPointForAllBEs(injection)
sql new
File("""${context.file.parent}/ddl/${tableName}_drop.sql""").text
@@ -104,32 +103,32 @@ suite("test_routine_load_restart_fe", "docker") {
} else {
continue;
}
- }
- sql "stop routine load for ${jobName}"
+ }
} catch (Exception e) {
log.info("exception: {}", e)
+ sql "stop routine load for ${jobName}"
sql "DROP TABLE IF EXISTS ${tableName}"
}
}
- }
- load_with_injection("KafkaDataConsumer.group_consume.out_of_range")
+ load_with_injection("KafkaDataConsumer.group_consume.out_of_range")
- cluster.restartFrontends()
- sleep(30000)
- context.reconnectFe()
+ cluster.restartFrontends()
+ sleep(30000)
+ context.reconnectFe()
- def res = sql "show routine load for ${jobName}"
- def state = res[0][8].toString()
- if (state == "PAUSED") {
- log.info("reason of state changed:
${res[0][17].toString()}".toString())
- assertTrue(res[0][17].toString().contains("Offset out of range"))
- assertTrue(res[0][17].toString().contains("consume partition"))
- assertTrue(res[0][17].toString().contains("consume offset"))
- } else {
- assertEquals(1, 2)
+ def res = sql "show routine load for ${jobName}"
+ def state = res[0][8].toString()
+ if (state == "PAUSED") {
+ log.info("reason of state changed:
${res[0][17].toString()}".toString())
+ assertTrue(res[0][17].toString().contains("Offset out of
range"))
+ assertTrue(res[0][17].toString().contains("consume partition"))
+ assertTrue(res[0][17].toString().contains("consume offset"))
+ } else {
+ assertEquals(1, 2)
+ }
+ sql "stop routine load for ${jobName}"
+ sql "DROP TABLE IF EXISTS ${tableName}"
}
- sql "stop routine load for ${jobName}"
- sql "DROP TABLE IF EXISTS ${tableName}"
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
