[bug] fix bug of getBrokerDesc object is null (#5295)

Co-authored-by: wangxiaobaidu11 <328642799@qq.com>
This commit is contained in:
XIAO WANG
2021-01-26 09:12:44 +08:00
committed by GitHub
parent 3db08a14bf
commit 067abac342

View File

@ -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!") ;