fix

vernedeng · Sep 14, 2024 · 1de8986 · 1de8986
1 parent a8caa4c
commit 1de8986
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ansform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/TransformProcessor.java b/...ansform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/TransformProcessor.java
@@ -167,7 +167,7 @@ public List<O> transform(I input, Map<String, Object> extParams) {
             for (ValueParserNode node : this.selectItems) {
                 String fieldName = node.getFieldName();
                 ValueParser parser = node.getParser();
-                if (parser == null && StringUtils.equals(fieldName, SinkEncoder.ALL_SOURCE_FIELD_SIGN)) {
+                if (parser == null || StringUtils.equals(fieldName, SinkEncoder.ALL_SOURCE_FIELD_SIGN)) {
                     if (input instanceof String) {
                         sinkData.addField(fieldName, (String) input);
                     } else {