From d4f8e0c754745fcc5eef8a4d87526eda05aed28e Mon Sep 17 00:00:00 2001 From: Henry2SS <45096548+Henry2SS@users.noreply.github.com> Date: Fri, 16 Sep 2022 10:30:57 +0800 Subject: [PATCH] [Bug](spark load) fix spark load clearSparkLauncherLog NPE #12619 Co-authored-by: wuhangze --- .../org/apache/doris/load/loadv2/SparkLoadJob.java | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/SparkLoadJob.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/SparkLoadJob.java index 2d1d2adef9..83fe2c7d64 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/SparkLoadJob.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/SparkLoadJob.java @@ -740,11 +740,13 @@ public class SparkLoadJob extends BulkLoadJob { } public void clearSparkLauncherLog() { - String logPath = sparkLoadAppHandle.getLogPath(); - if (!Strings.isNullOrEmpty(logPath)) { - File file = new File(logPath); - if (file.exists()) { - file.delete(); + if (sparkLoadAppHandle != null) { + String logPath = sparkLoadAppHandle.getLogPath(); + if (!Strings.isNullOrEmpty(logPath)) { + File file = new File(logPath); + if (file.exists()) { + file.delete(); + } } } }