[INLONG-8992][Manager] Fix NPE when using transform (#8993)

apache · Sep 25, 2023 · 2cf161d · 2cf161d
1 parent 0b3fdfc
commit 2cf161d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...ager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/NodeFactory.java b/...ager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/NodeFactory.java
@@ -105,7 +105,9 @@ public static List<Node> addBuiltInField(StreamSource sourceInfo, StreamSink sin
 
         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());
         }