You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/05/05 07:02:37 UTC

[incubator-inlong] branch master updated: [INLONG-4067][Manager] Optimize fieldRelationShip in split transform (#4068)

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 141903521 [INLONG-4067][Manager] Optimize fieldRelationShip in split transform (#4068)
141903521 is described below

commit 141903521f1f2330e9a165b0f03d3dc21134936a
Author: kipshi <48...@users.noreply.github.com>
AuthorDate: Thu May 5 15:02:32 2022 +0800

    [INLONG-4067][Manager] Optimize fieldRelationShip in split transform (#4068)
---
 .../apache/inlong/manager/service/sort/util/FieldRelationShipUtils.java  | 1 +
 1 file changed, 1 insertion(+)

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 20d7310bb..08de0625e 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
@@ -171,6 +171,7 @@ public class FieldRelationShipUtils {
             FieldInfo targetFieldInfo = new FieldInfo(
                     targetSources.get(index), transformName, FieldInfoUtils.convertFieldFormat(FieldType.STRING.name())
             );
+            splitFields.add(targetSources.get(index));
             splitRelationShips.add(new FieldRelationShip(splitIndexFunction, targetFieldInfo));
         }
         return splitRelationShips;