diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/OlapTableSink.java b/fe/fe-core/src/main/java/org/apache/doris/planner/OlapTableSink.java index 3e51feb703c866..72e244d3f1f07a 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/planner/OlapTableSink.java +++ b/fe/fe-core/src/main/java/org/apache/doris/planner/OlapTableSink.java @@ -858,6 +858,9 @@ public TPaloNodesInfo createPaloNodesInfo() { SystemInfoService systemInfoService = Env.getCurrentSystemInfo(); for (Long id : systemInfoService.getAllBackendIds(false)) { Backend backend = systemInfoService.getBackend(id); + if (backend == null) { + continue; + } nodesInfo.addToNodes(new TNodeInfo(backend.getId(), 0, backend.getHost(), backend.getBrpcPort())); } return nodesInfo;