fix

vernedeng · Oct 18, 2023 · fd1abca · fd1abca
1 parent b7ce4b9
commit fd1abca
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...vice/src/main/java/org/apache/inlong/manager/service/core/impl/SortSourceServiceImpl.java b/...vice/src/main/java/org/apache/inlong/manager/service/core/impl/SortSourceServiceImpl.java
@@ -237,6 +237,7 @@ private void reloadAllConfigs() {
         // reload all streams
         allStreams = configLoader.loadAllStreams()
                 .stream()
+                .filter(stream -> StringUtils.isNotBlank(stream.getMqResource()))
                 .collect(Collectors.groupingBy(SortSourceStreamInfo::getInlongGroupId,
                         Collectors.toMap(SortSourceStreamInfo::getInlongStreamId, info -> info)));