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 <[email protected]>
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())
