[inlong] branch master updated: [INLONG-8992][Manager] Fix NPE when using transform (#8993)

[vernedeng]

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

vernedeng 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 2cf161d2ab [INLONG-8992][Manager] Fix NPE when using transform (#8993)
2cf161d2ab is described below

commit 2cf161d2ab9b413eddef16c5a3c5c14989180f7a
Author: haifxu <xhf1208357...@gmail.com>
AuthorDate: Mon Sep 25 19:27:49 2023 +0800

    [INLONG-8992][Manager] Fix NPE when using transform (#8993)
---
 .../java/org/apache/inlong/manager/pojo/sort/node/NodeFactory.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/NodeFactory.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/NodeFactory.java
index 74f2efae00..fdf68e0ce9 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/NodeFactory.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/NodeFactory.java
@@ -105,7 +105,9 @@ public class NodeFactory {
 
         if (FieldInfoUtils.compareFields(extractNodeProvider.getMetaFields(), 
loadNodeProvider.getMetaFields())) {
             extractNodeProvider.addStreamMetaFields(sourceInfo.getFieldList());
-            transformResponses.forEach(v -> 
extractNodeProvider.addStreamMetaFields(v.getFieldList()));
+            if (CollectionUtils.isNotEmpty(transformResponses)) {
+                transformResponses.forEach(v -> 
extractNodeProvider.addStreamMetaFields(v.getFieldList()));
+            }
             loadNodeProvider.addSinkMetaFields(sinkInfo.getSinkFieldList());
         }