You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2024/09/20 09:25:35 UTC
(inlong) branch master updated: [INLONG-11150][Manager] Fix the problem of incorrect setting of sorTaskName for sink (#11151)
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 <76...@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);
}