Skip to content

Commit aa0e8d4

Browse files
authored
[Fix](fe) Fix NPE in OlapTableSink.createPaloNodesInfo due to concurrent drop backend (#58999)
1 parent 58e3f6d commit aa0e8d4

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

fe/fe-core/src/main/java/org/apache/doris/planner/OlapTableSink.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -866,6 +866,9 @@ public TPaloNodesInfo createPaloNodesInfo() {
866866
SystemInfoService systemInfoService = Env.getCurrentSystemInfo();
867867
for (Long id : systemInfoService.getAllBackendIds(false)) {
868868
Backend backend = systemInfoService.getBackend(id);
869+
if (backend == null) {
870+
continue;
871+
}
869872
nodesInfo.addToNodes(new TNodeInfo(backend.getId(), 0, backend.getHost(), backend.getBrpcPort()));
870873
}
871874
return nodesInfo;

0 commit comments

Comments
 (0)