diff --git a/CHANGES.md b/CHANGES.md index a06f660ab..b38bac249 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -18,7 +18,8 @@ Release Notes. * Support influxDB connection response format option. Fix some error when use JSON as influxDB response format. * Support Kafka MirrorMaker 2.0 to replicate topics between Kafka clusters. * Add the rule name field to alarm record storage entity as a part of ID, to support multiple alarm rules triggered for one entity. The scope id has been removed from the ID. -* Fix MAL concurrent execution issues +* Fix MAL concurrent execution issues. +* Fix group name can't be query in the GraphQL. #### UI * Fix un-removed tags in trace query. diff --git a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/query/MetadataQueryService.java b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/query/MetadataQueryService.java index 696dcb195..a5f1e8b2f 100644 --- a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/query/MetadataQueryService.java +++ b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/query/MetadataQueryService.java @@ -20,6 +20,8 @@ package org.apache.skywalking.oap.server.core.query; import java.io.IOException; import java.util.List; +import java.util.stream.Collectors; +import org.apache.skywalking.oap.server.core.Const; import org.apache.skywalking.oap.server.core.analysis.IDManager; import org.apache.skywalking.oap.server.core.query.type.Database; import org.apache.skywalking.oap.server.core.query.type.Endpoint; @@ -47,7 +49,13 @@ public class MetadataQueryService implements org.apache.skywalking.oap.server.li } public List getAllServices(final String group) throws IOException { - return getMetadataQueryDAO().getAllServices(group); + return getMetadataQueryDAO().getAllServices(group).stream() + .map(service -> { + if (service.getGroup() == null) { + service.setGroup(Const.EMPTY_STRING); + } + return service; + }).collect(Collectors.toList()); } public List getAllBrowserServices() throws IOException {