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 cf1e029178..0554952f67 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 @@ -102,7 +102,7 @@ public class LoadManager implements Writable{ LoadJob loadJob = null; writeLock(); try { - if (stmt.getBrokerDesc().isMultiLoadBroker()) { + if (stmt.getBrokerDesc() != null && stmt.getBrokerDesc().isMultiLoadBroker()) { if (!Catalog.getCurrentCatalog().getLoadInstance() .isUncommittedLabel(dbId, stmt.getLabel().getLabelName())) { throw new DdlException("label: " + stmt.getLabel().getLabelName() + " not found!") ;