This is an automated email from the ASF dual-hosted git repository. zhangliang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push: new 0f9c7271b77 Refactor ShowComputeNodesExecutor (#34983) 0f9c7271b77 is described below commit 0f9c7271b777e30fe97ea8ce20d0afd38a612bdd Author: Liang Zhang <zhangli...@apache.org> AuthorDate: Fri Mar 14 01:24:25 2025 +0800 Refactor ShowComputeNodesExecutor (#34983) --- .../ral/queryable/computenode/ShowComputeNodesExecutor.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/computenode/ShowComputeNodesExecutor.java b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/computenode/ShowComputeNodesExecutor.java index 41c334ae90e..c6ad283cca3 100644 --- a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/computenode/ShowComputeNodesExecutor.java +++ b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/computenode/ShowComputeNodesExecutor.java @@ -43,9 +43,10 @@ public final class ShowComputeNodesExecutor implements DistSQLQueryExecutor<Show @Override public Collection<LocalDataQueryResultRow> getRows(final ShowComputeNodesStatement sqlStatement, final ContextManager contextManager) { String modeType = contextManager.getComputeNodeInstanceContext().getModeConfiguration().getType(); - return "Standalone".equals(modeType) - ? Collections.singleton(buildRow(contextManager.getComputeNodeInstanceContext().getInstance(), modeType)) - : contextManager.getPersistServiceFacade().getComputeNodePersistService().loadAllInstances().stream().map(each -> buildRow(each, modeType)).collect(Collectors.toList()); + Collection<ComputeNodeInstance> instances = "Standalone".equals(modeType) + ? Collections.singleton(contextManager.getComputeNodeInstanceContext().getInstance()) + : contextManager.getPersistServiceFacade().getComputeNodePersistService().loadAllInstances(); + return instances.stream().map(each -> buildRow(each, modeType)).collect(Collectors.toList()); } private LocalDataQueryResultRow buildRow(final ComputeNodeInstance instance, final String modeType) {