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

Fix NullPointerException when creating mini load in LoadManager (#1565)

Browse Source 
The catch statement cancel the load job in the function named createMiniLoad.
But sometimes, the load job hasn't been created in catch statement. It will throw the NullPointerException when the load job is cancelled.
This commit fix this bug.
This commit is contained in:
EmmyMiao87
2019-07-30 12:52:14 +08:00
committed by Mingyu Chen
parent e0d991f4dc
commit 8bc8fcffae
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/src/main/java/org/apache/doris/load/loadv2/LoadManager.java
View File

@ -149,7 +149,9 @@ public class LoadManager implements Writable{
.stream().filter(entity -> entity.getState() != JobState.CANCELLED).findFirst()
.get().getTransactionId();
} catch (UserException e) {
loadJob.cancelJobWithoutCheck(new FailMsg(LOAD_RUN_FAIL, e.getMessage()), false);
if (loadJob != null) {
loadJob.cancelJobWithoutCheck(new FailMsg(LOAD_RUN_FAIL, e.getMessage()), false);
}
throw e;
} finally {
writeUnlock();