This is an automated email from the ASF dual-hosted git repository.
hellostephen 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 5475f26b740 [fix](test) fix test_routine_load_restart_fe fail (#53266)
5475f26b740 is described below
commit 5475f26b7403b188e6d7491d945c80d96e2fa7c1
Author: hui lai <[email protected]>
AuthorDate: Tue Jul 15 17:00:17 2025 +0800
[fix](test) fix test_routine_load_restart_fe fail (#53266)
---
.../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 daa93cffd03..cedbf998e47 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
@@ -75,15 +75,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
@@ -129,32 +128,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]
