fix memory leak in FE observer node

apache · Jan 16, 2025 · cb7122f · cb7122f
1 parent 2466d08
commit cb7122f
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -544,6 +544,7 @@ private void jobRemovedTrigger(LoadJob job) {
         if (map.isEmpty()) {
             dbIdToLabelToLoadJobs.remove(job.getDbId());
         }
+        Env.getCurrentGlobalTransactionMgr().getCallbackFactory().removeCallback(job.getId());
     }
 
     private void removeLoadJobIf(Predicate<LoadJob> pred) {