From 8bc8fcffae29b8dd2ff07dd780c3c9826883b10c Mon Sep 17 00:00:00 2001 From: EmmyMiao87 <522274284@qq.com> Date: Tue, 30 Jul 2019 12:52:14 +0800 Subject: [PATCH] Fix NullPointerException when creating mini load in LoadManager (#1565) 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. --- .../main/java/org/apache/doris/load/loadv2/LoadManager.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/fe/src/main/java/org/apache/doris/load/loadv2/LoadManager.java b/fe/src/main/java/org/apache/doris/load/loadv2/LoadManager.java index 455984089b..df88a0c005 100644 --- a/fe/src/main/java/org/apache/doris/load/loadv2/LoadManager.java +++ b/fe/src/main/java/org/apache/doris/load/loadv2/LoadManager.java @@ -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();