This is an automated email from the ASF dual-hosted git repository.
healchow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new dc19bba2d [INLONG-4183][Manager] Fix splitFields in manager service
(#4184)
dc19bba2d is described below
commit dc19bba2d5c60f786c873378e6762a3d6d0b950b
Author: kipshi <[email protected]>
AuthorDate: Fri May 13 12:24:08 2022 +0800
[INLONG-4183][Manager] Fix splitFields in manager service (#4184)
---
.../apache/inlong/manager/service/sort/util/FieldRelationShipUtils.java | 1 -
1 file changed, 1 deletion(-)
diff --git
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sort/util/FieldRelationShipUtils.java
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sort/util/FieldRelationShipUtils.java
index 59d498c54..51769a38f 100644
---
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sort/util/FieldRelationShipUtils.java
+++
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sort/util/FieldRelationShipUtils.java
@@ -183,7 +183,6 @@ public class FieldRelationShipUtils {
private static List<FieldRelationShip> parseSplitRule(SplitRule splitRule,
Set<String> splitFields,
String transformName, String preNode) {
StreamField sourceField = splitRule.getSourceField();
- splitFields.add(sourceField.getFieldName());
FieldInfo fieldInfo = FieldInfoUtils.parseStreamField(sourceField);
fieldInfo.setNodeId(preNode);
String seperator = splitRule.getSeperator();