diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadJob.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadJob.java index bd8d09d5c6..946d116b51 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadJob.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadJob.java @@ -826,8 +826,12 @@ public abstract class LoadJob extends AbstractTxnStateChangeCallback implements jobInfo.add(transactionId); // error tablets jobInfo.add(errorTabletsToJson()); - // user - jobInfo.add(userInfo.getQualifiedUser()); + // user, some load job may not have user info + if (userInfo == null || userInfo.getQualifiedUser() == null) { + jobInfo.add(FeConstants.null_string); + } else { + jobInfo.add(userInfo.getQualifiedUser()); + } // comment jobInfo.add(comment); return jobInfo; diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManager.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManager.java index 3eacb9f66c..cf2a408ac7 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManager.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManager.java @@ -572,8 +572,9 @@ public class LoadManager implements Writable { } // add load job info loadJobInfos.add(loadJob.getShowInfo()); - } catch (DdlException e) { - continue; + } catch (RuntimeException | DdlException e) { + // ignore this load job + LOG.warn("get load job info failed. job id: {}", loadJob.getId(), e); } } return loadJobInfos;