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 5e90377c9ed branch-3.0: [fix](cloud)(bulk load) fix memory leak in FE
observer node #47074 (#47244)
5e90377c9ed is described below
commit 5e90377c9edb33c2619914411fc7977e8c2a81a8
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Jan 23 13:15:46 2025 +0800
branch-3.0: [fix](cloud)(bulk load) fix memory leak in FE observer node
#47074 (#47244)
Cherry-picked from #47074
Co-authored-by: hui lai <lai...@selectdb.com>
---
fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManager.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManager.java
b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManager.java
index 07c459d61cf..f661513cd66 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManager.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManager.java
@@ -336,6 +336,7 @@ public class LoadManager implements Writable {
LOG.info(new LogBuilder(LogKey.LOAD_JOB,
operation.getId()).add("operation", operation)
.add("msg", "replay end load job").build());
+
Env.getCurrentGlobalTransactionMgr().getCallbackFactory().removeCallback(operation.getId());
// When idToLoadJob size increase 10000 roughly, we run
removeOldLoadJob to reduce mem used
if ((idToLoadJob.size() > 0) && (idToLoadJob.size() % 10000 == 0)) {
removeOldLoadJob();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
