database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](load) fix NPE in LoadManager#jobRemovedTrigger() (#36173) (#36337)

Browse Source 
cherry-pick #36173
This commit is contained in:
Kaijie Chen
2024-06-15 23:06:31 +08:00
committed by GitHub
parent bfab7a2537
commit 55b4cf1658
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManager.java
View File

@ -451,15 +451,21 @@ public class LoadManager implements Writable {
}
private void jobRemovedTrigger(LoadJob job) {
Map<String, List<LoadJob>> map = dbIdToLabelToLoadJobs.get(job.getDbId());
List<LoadJob> list = map.get(job.getLabel());
list.remove(job);
if (job instanceof SparkLoadJob) {
((SparkLoadJob) job).clearSparkLauncherLog();
}
if (job instanceof BulkLoadJob) {
((BulkLoadJob) job).recycleProgress();
}
Map<String, List<LoadJob>> map = dbIdToLabelToLoadJobs.get(job.getDbId());
if (map == null) {
return;
}
List<LoadJob> list = map.get(job.getLabel());
if (list == null) {
return;
}
list.remove(job);
if (list.isEmpty()) {
map.remove(job.getLabel());
}