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

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

Signed-off-by: sevev <qiangzh95@gmail.com>
This commit is contained in:
zhangqiang 2025-10-10 14:37:24 +08:00 committed by GitHub
parent 4a3092a306
commit 707b3c4a7a
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

@ -400,11 +400,13 @@ public class LoadMgr implements 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);