[INLONG-11150][Manager] Fix the problem of incorrect setting of sorTa…

…skName for sink
fuweng11 · Sep 20, 2024 · 6796ddc · 6796ddc
1 parent f1ccde4
commit 6796ddc
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/...g/apache/inlong/manager/service/resource/sink/AbstractStandaloneSinkResourceOperator.java b/...g/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);
     }