tool
/
starrocks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[BugFix] Fix nullptr exception during remove expried load job (backport #63820) (#63879) 

Signed-off-by: sevev <qiangzh95@gmail.com>
Co-authored-by: zhangqiang <qiangzh95@gmail.com>
This commit is contained in:
mergify[bot] 2025-10-10 07:39:20 +00:00 committed by GitHub
parent 994b547704
commit e1e42d50b9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
fe/fe-core/src/main/java/com/starrocks/load/loadv2/LoadMgr.java
View File

@ -390,11 +390,13 @@ public class LoadMgr implements Writable, MemoryTrackable {
// 2. remove from dbIdToLabelToLoadJobs
Map<String, List<LoadJob>> labelToLoadJobs = dbIdToLabelToLoadJobs.get(dbId);
List<LoadJob> sameLabelJobs = labelToLoadJobs.get(label);
if (sameLabelJobs != null) {
sameLabelJobs.remove(job);
if (sameLabelJobs.isEmpty()) {
labelToLoadJobs.remove(label);
if (labelToLoadJobs != null) {
List<LoadJob> sameLabelJobs = labelToLoadJobs.get(label);
if (sameLabelJobs != null) {
sameLabelJobs.remove(job);
if (sameLabelJobs.isEmpty()) {
labelToLoadJobs.remove(label);
}
}
if (labelToLoadJobs.isEmpty()) {
dbIdToLabelToLoadJobs.remove(dbId);