(inlong) branch master updated: [INLONG-11150][Manager] Fix the problem of incorrect setting of sorTaskName for sink (#11151)

[dockerzhang]

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

dockerzhang 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 0d00999961 [INLONG-11150][Manager] Fix the problem of incorrect 
setting of sorTaskName for sink (#11151)
0d00999961 is described below

commit 0d00999961b29b36b4152dd066494aae67473e4b
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Fri Sep 20 17:25:30 2024 +0800

    [INLONG-11150][Manager] Fix the problem of incorrect setting of sorTaskName 
for sink (#11151)
---
 .../resource/sink/AbstractStandaloneSinkResourceOperator.java  | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/AbstractStandaloneSinkResourceOperator.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/AbstractStandaloneSinkResourceOperator.java
index d5a97a42b1..d1842fb02c 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/AbstractStandaloneSinkResourceOperator.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/AbstractStandaloneSinkResourceOperator.java
@@ -89,13 +89,13 @@ public abstract class 
AbstractStandaloneSinkResourceOperator implements SinkReso
         if (!StringUtils.isAnyBlank(sinkInfo.getSortConsumerGroup(), 
sinkInfo.getSortTaskName())) {
             return;
         }
-        if (StringUtils.isBlank(sinkInfo.getSortConsumerGroup())) {
-            sinkInfo.setSortConsumerGroup(sinkInfo.getDataNodeName());
+        StreamSinkEntity sink = 
sinkEntityMapper.selectByPrimaryKey(sinkInfo.getId());
+        if (StringUtils.isBlank(sink.getSortConsumerGroup())) {
+            sink.setSortConsumerGroup(sink.getDataNodeName());
         }
-        if (StringUtils.isBlank(sinkInfo.getSortTaskName())) {
-            sinkInfo.setSortTaskName(sinkInfo.getDataNodeName());
+        if (StringUtils.isBlank(sink.getSortTaskName())) {
+            sink.setSortTaskName(sink.getDataNodeName());
         }
-        StreamSinkEntity sink = 
sinkEntityMapper.selectByPrimaryKey(sinkInfo.getId());
         sinkEntityMapper.updateByIdSelective(sink);
     }