diff --git a/fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/CheckWalSizeAction.java b/fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/CheckWalSizeAction.java index fdc39e8bad..2f963be8c2 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/CheckWalSizeAction.java +++ b/fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/CheckWalSizeAction.java @@ -61,36 +61,36 @@ public class CheckWalSizeAction extends RestBaseController { checkGlobalAuth(ConnectContext.get().getCurrentUserIdentity(), PrivPredicate.OPERATOR); String hostPorts = request.getParameter(HOST_PORTS); + List backends = new ArrayList<>(); if (Strings.isNullOrEmpty(hostPorts)) { - return ResponseEntityBuilder.badRequest("No host:port specified"); - } - - String[] hostPortArr = hostPorts.split(","); - if (hostPortArr.length == 0) { - return ResponseEntityBuilder.badRequest("No host:port specified"); - } - - List hostInfos = Lists.newArrayList(); - for (String hostPort : hostPortArr) { + backends = Env.getCurrentSystemInfo().getAllBackends(); + } else { + String[] hostPortArr = hostPorts.split(","); + if (hostPortArr.length == 0) { + return ResponseEntityBuilder.badRequest("No host:port specified"); + } + List hostInfos = new ArrayList<>(); + for (String hostPort : hostPortArr) { + try { + HostInfo hostInfo = SystemInfoService.getHostAndPort(hostPort); + hostInfos.add(hostInfo); + } catch (AnalysisException e) { + return ResponseEntityBuilder.badRequest(e.getMessage()); + } + } try { - HostInfo hostInfo = SystemInfoService.getHostAndPort(hostPort); - hostInfos.add(hostInfo); - } catch (AnalysisException e) { - return ResponseEntityBuilder.badRequest(e.getMessage()); + backends = getBackends(hostInfos); + } catch (DdlException e) { + return ResponseEntityBuilder.okWithCommonError(e.getMessage()); } } - try { - List backends = getBackends(hostInfos); - List backendsList = new ArrayList<>(); - for (Backend backend : backends) { - long size = Env.getCurrentEnv().getGroupCommitManager().getAllWalQueueSize(backend); - backendsList.add(backend.getHost() + ":" + backend.getHeartbeatPort() + ":" + size); - } - return ResponseEntityBuilder.ok(backendsList); - } catch (DdlException e) { - return ResponseEntityBuilder.okWithCommonError(e.getMessage()); + List backendsList = new ArrayList<>(); + for (Backend backend : backends) { + long size = Env.getCurrentEnv().getGroupCommitManager().getAllWalQueueSize(backend); + backendsList.add(backend.getHost() + ":" + backend.getHeartbeatPort() + ":" + size); } + return ResponseEntityBuilder.ok(backendsList); } private List getBackends(List hostInfos) throws DdlException {