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 ff482cc5297 branch-3.0: [fix](test) do not close producer immediately
after send #54851 (#54883)
ff482cc5297 is described below
commit ff482cc5297e2199e23bba9393897e5c8dd4b90c
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat Aug 16 16:06:55 2025 +0800
branch-3.0: [fix](test) do not close producer immediately after send #54851
(#54883)
Cherry-picked from #54851
Co-authored-by: hui lai <[email protected]>
---
.../suites/load_p0/routine_load/test_multi_table_load_restart.groovy | 1 -
.../suites/load_p0/routine_load/test_routine_load_follower_fe.groovy | 1 -
.../suites/load_p0/routine_load/test_routine_load_job_schedule.groovy | 1 -
.../suites/load_p0/routine_load/test_routine_load_jsonpath_dollar.groovy | 1 -
4 files changed, 4 deletions(-)
diff --git
a/regression-test/suites/load_p0/routine_load/test_multi_table_load_restart.groovy
b/regression-test/suites/load_p0/routine_load/test_multi_table_load_restart.groovy
index d89f513eb5d..88e62da64b7 100644
---
a/regression-test/suites/load_p0/routine_load/test_multi_table_load_restart.groovy
+++
b/regression-test/suites/load_p0/routine_load/test_multi_table_load_restart.groovy
@@ -117,7 +117,6 @@ suite("test_multi_table_load_restart","docker") {
producer.send(record)
}
}
- producer.close()
def count = 0
def maxWaitCount = 60
diff --git
a/regression-test/suites/load_p0/routine_load/test_routine_load_follower_fe.groovy
b/regression-test/suites/load_p0/routine_load/test_routine_load_follower_fe.groovy
index 8f7ed9a4cf6..b2582a571a8 100644
---
a/regression-test/suites/load_p0/routine_load/test_routine_load_follower_fe.groovy
+++
b/regression-test/suites/load_p0/routine_load/test_routine_load_follower_fe.groovy
@@ -87,7 +87,6 @@ suite("test_routine_load_follower_fe","docker") {
producer.send(record)
}
}
- producer.close()
// 3. Connect to a follower FE and create table
def masterFe = cluster.getMasterFe()
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 cb8fba35830..ed52e60a13f 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
@@ -50,7 +50,6 @@ suite("test_routine_load_job_schedule","nonConcurrent") {
def record = new ProducerRecord<>(kafkaCsvTpoics[0], null, line)
producer.send(record)
}
- producer.close()
def tableName = "test_routine_load_job_schedule"
def job = "test_routine_load_job_schedule"
diff --git
a/regression-test/suites/load_p0/routine_load/test_routine_load_jsonpath_dollar.groovy
b/regression-test/suites/load_p0/routine_load/test_routine_load_jsonpath_dollar.groovy
index a4ade95f27d..f77abe9db89 100644
---
a/regression-test/suites/load_p0/routine_load/test_routine_load_jsonpath_dollar.groovy
+++
b/regression-test/suites/load_p0/routine_load/test_routine_load_jsonpath_dollar.groovy
@@ -41,7 +41,6 @@ suite("test_routine_load_jsonpath_dollar", "p0") {
def record = new ProducerRecord<>(jobName, null, line)
producer.send(record)
}
- producer.close()
try {
sql """
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
