(inlong) branch master updated: [INLONG-10997][Manager] Incorrect setting of transformSQL in dataflowconfig (#10998)

[aloyszhang]

This is an automated email from the ASF dual-hosted git repository.

aloyszhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new e188410668 [INLONG-10997][Manager] Incorrect setting of transformSQL 
in dataflowconfig (#10998)
e188410668 is described below

commit e1884106681a4062555d413f6f2cdc24ef741229
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Tue Sep 3 14:07:56 2024 +0800

    [INLONG-10997][Manager] Incorrect setting of transformSQL in dataflowconfig 
(#10998)
---
 .../inlong/manager/service/resource/sort/DefaultSortConfigOperator.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sort/DefaultSortConfigOperator.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sort/DefaultSortConfigOperator.java
index 116a8f0ea2..17ca4b9bad 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sort/DefaultSortConfigOperator.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sort/DefaultSortConfigOperator.java
@@ -175,6 +175,7 @@ public class DefaultSortConfigOperator implements 
SortConfigOperator {
                 .dataflowId(String.valueOf(sink.getId()))
                 .sourceConfig(getSourceConfig(groupInfo, streamInfo, sink))
                 .auditTag(String.valueOf(sink.getId()))
+                .transformSql(sink.getTransformSql())
                 .sinkConfig(getSinkConfig(groupInfo, streamInfo, sink))
                 .inlongGroupId(groupInfo.getInlongGroupId())
                 .inlongStreamId(streamInfo.getInlongStreamId())