From 0d00999961b29b36b4152dd066494aae67473e4b Mon Sep 17 00:00:00 2001
From: fuweng11 <76141879+fuweng11@users.noreply.github.com>
Date: Fri, 20 Sep 2024 17:25:30 +0800
Subject: [PATCH] [INLONG-11150][Manager] Fix the problem of incorrect setting
 of sorTaskName for sink (#11151)

---
 .../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 @@ protected void checkTaskAndConsumerGroup(SinkInfo sinkInfo) {
         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);
     }