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 74f2efae00d..fdf68e0ce9c 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 static List 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()); }