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

[dockerzhang]

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

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


The following commit(s) were added to refs/heads/branch-1.9 by this push:
     new 974f913d82 [INLONG-8992][Manager] Fix NPE when using transform (#8993)
974f913d82 is described below

commit 974f913d82d344a87737b0c584d7e5aea7ecb5f4
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());
         }