Memory leak exception occurs when reading data with the Doris connector
- Dominant language
- Java
- Stars
- 9.7k
- Forks
- 2.4k
- Avg merge
- 3d 17h
- Merged PRs (30d)
- 210
Description
### Search before asking
- [x] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues.
### What happened
使用Doris连接器读取数据时报内存泄漏异常,导致无法读取数据近而没有数据输出到控制台。
### SeaTunnel Version
v2.3.11
### SeaTunnel Config
```conf
{
"env": {
"job.name": "单表查询Doris表中指定字段数据",
"job.mode": "batch",
"parallelism": 1,
"checkpoint.interval": 10000,
"checkpoint.timeout": 60000
},
"source": [
{
"plugin_name": "doris",
"fenodes": "192.168.0.60:8030",
"username": "root",
"password": "",
"doris.request.retries": 1,
"doris.request.read.timeout.ms": 10000,
"doris.request.connect.timeout.ms": 10000,
"query-port": 9030,
"doris.request.query.timeout.s": 3600,
"database": "seatunnel",
"table": "example_tb_duplicate_key",
"doris.deserialize.arrow.async": false,
"doris.batch.size": 1024,
"doris.exec.mem.limit": 2147483648
}
],
"sink": [
{
"plugin_name": "console"
}
]
}
```
### Running Command
```shell
调用API运行任务
```
### Error Exception
```log
[1019791029655568385] 2025-09-15 10:05:32,122 ERROR [o.a.s.e.s.d.p.PhysicalVertex ] [hz.main.seaTunnel.task.thread-174] - Job (1019791029655568385), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-doris]-SourceTask (1/1)], taskGroupLocation: [TaskGroupLocation{jobId=1019791029655568385, pipelineId=1, taskGroupId=2}] end with state FAILED and Exception: java.lang.IllegalStateException: Memory was leaked by query. Memory leaked: (64)
Allocator(ROOT) 0/64/64/2147483647 (res/actual/peak/limit)
at org.apache.seatunnel.shade.org.apache.arrow.memory.BaseAllocator.close(BaseAllocator.java:477)
at org.apache.seatunnel.shade.org.apache.arrow.memory.RootAllocator.close(RootAllocator.java:29)
at org.apache.seatunnel.connectors.seatunnel.common.source.arrow.reader.ArrowToSeatunnelRowReader.close(ArrowToSeatunnelRowReader.java:295)
at org.apache.seatunnel.connectors.seatunnel.common.source.arrow.reader.ArrowToSeatunnelRowReader.readArrow(ArrowToSeatunnelRowReader.java:117)
at org.apache.seatunnel.connectors.doris.source.reader.DorisValueReader.hasNext(DorisValueReader.java:241)
at org.apache.seatunnel.connectors.doris.source.reader.DorisSourceReader.pollNext(DorisSourceReader.java:90)
at org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.collect(SourceFlowLifeCycle.java:159)
at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:127)
at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:165)
at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:132)
at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:694)
at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1023)
at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:842)
```
### Zeta or Flink or Spark Version
_No response_
### Java or Scala Version
_No response_
### Screenshots
_No response_
### Are you willing to submit PR?
- [ ] Yes I am willing to submit a PR!
### Code of Conduct
- [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.