[inlong] branch master updated: [INLONG-8072][Manager] Fix NPE when taskName of streamSink is empty or null (#8076)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new e8efb061b [INLONG-8072][Manager] Fix NPE when taskName of streamSink 
is empty or null (#8076)
e8efb061b is described below

commit e8efb061b8d7faaea048c87982ce4463e15da559
Author: vernedeng <deng...@pku.edu.cn>
AuthorDate: Tue May 23 18:23:44 2023 +0800

    [INLONG-8072][Manager] Fix NPE when taskName of streamSink is empty or null 
(#8076)
    
    Co-authored-by: vernedeng <verned...@github.com>
---
 .../apache/inlong/manager/service/core/impl/SortClusterServiceImpl.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortClusterServiceImpl.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortClusterServiceImpl.java
index 0a6996a87..57418caac 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortClusterServiceImpl.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortClusterServiceImpl.java
@@ -184,6 +184,8 @@ public class SortClusterServiceImpl implements 
SortClusterService {
         // get all stream sinks
         Map<String, List<StreamSinkEntity>> task2AllStreams = 
sinkEntities.stream()
                 .filter(entity -> 
StringUtils.isNotBlank(entity.getInlongClusterName()))
+                .filter(entity -> 
StringUtils.isNotBlank(entity.getSortTaskName()))
+                .filter(entity -> 
StringUtils.isNotBlank(entity.getDataNodeName()))
                 
.collect(Collectors.groupingBy(StreamSinkEntity::getSortTaskName));
 
         // get all data nodes and group by node name