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 a56a84e6426 branch-3.1: [fix](test) fix test_routine_load_job_schedule
unstable #54341 (#54365)
a56a84e6426 is described below
commit a56a84e6426e3ba34d0f13140212620f993a087c
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Aug 6 15:10:14 2025 +0800
branch-3.1: [fix](test) fix test_routine_load_job_schedule unstable #54341
(#54365)
Cherry-picked from #54341
Co-authored-by: hui lai <[email protected]>
---
.../load_p0/routine_load/test_routine_load_job_schedule.groovy | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
diff --git
a/regression-test/suites/load_p0/routine_load/test_routine_load_job_schedule.groovy
b/regression-test/suites/load_p0/routine_load/test_routine_load_job_schedule.groovy
index c892d9dbde0..34aa115f7b5 100644
---
a/regression-test/suites/load_p0/routine_load/test_routine_load_job_schedule.groovy
+++
b/regression-test/suites/load_p0/routine_load/test_routine_load_job_schedule.groovy
@@ -38,7 +38,6 @@ suite("test_routine_load_job_schedule","nonConcurrent") {
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
"org.apache.kafka.common.serialization.StringSerializer")
def producer = new KafkaProducer<>(props)
def adminClient = AdminClient.create(props)
- def newTopic = new NewTopic(kafkaCsvTpoics[0], 5, (short)1)
def testData = [
"1,test_data_1,2023-01-01,value1,2023-01-01 10:00:00,extra1",
"2,test_data_2,2023-01-02,value2,2023-01-02 11:00:00,extra2",
@@ -46,10 +45,9 @@ suite("test_routine_load_job_schedule","nonConcurrent") {
"4,test_data_4,2023-01-04,value4,2023-01-04 13:00:00,extra4",
"5,test_data_5,2023-01-05,value5,2023-01-05 14:00:00,extra5"
]
- adminClient.createTopics(Collections.singletonList(newTopic))
- testData.eachWithIndex { line, index ->
+ testData.each { line->
logger.info("Sending data to kafka: ${line}")
- def record = new ProducerRecord<>(newTopic.name(), index, null,
line)
+ def record = new ProducerRecord<>(kafkaCsvTpoics[0], null, line)
producer.send(record)
}
producer.close()
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
