This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new 568b1782ca6 branch-4.0: [fix](scheduler) Fix TaskDisruptor event loss
due to wrong ProducerType #60238 (#60357)
568b1782ca6 is described below
commit 568b1782ca6c65b2414f6d7bbfe7624e79d754db
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Feb 2 11:11:44 2026 +0800
branch-4.0: [fix](scheduler) Fix TaskDisruptor event loss due to wrong
ProducerType #60238 (#60357)
Cherry-picked from #60238
Co-authored-by: Xin Liao <[email protected]>
---
.../main/java/org/apache/doris/scheduler/disruptor/TaskDisruptor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/scheduler/disruptor/TaskDisruptor.java
b/fe/fe-core/src/main/java/org/apache/doris/scheduler/disruptor/TaskDisruptor.java
index 8144ca22ea2..9be30124c9e 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/scheduler/disruptor/TaskDisruptor.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/scheduler/disruptor/TaskDisruptor.java
@@ -75,7 +75,7 @@ public class TaskDisruptor implements Closeable {
public void start() {
CustomThreadFactory exportTaskThreadFactory = new
CustomThreadFactory("export-task-consumer");
disruptor = new Disruptor<>(TaskEvent.FACTORY,
DEFAULT_RING_BUFFER_SIZE, exportTaskThreadFactory,
- ProducerType.SINGLE, new LiteTimeoutBlockingWaitStrategy(10,
TimeUnit.MILLISECONDS));
+ ProducerType.MULTI, new LiteTimeoutBlockingWaitStrategy(10,
TimeUnit.MILLISECONDS));
WorkHandler<TaskEvent>[] workers = new
TaskHandler[consumerThreadCount];
for (int i = 0; i < consumerThreadCount; i++) {
workers[i] = new TaskHandler();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
