(inlong) 01/02: [INLONG-9444][Manager] ES sink unsuccessful flow status configuration successful (#9445)

[vernedeng]

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

vernedeng pushed a commit to branch branch-1.10
in repository https://gitbox.apache.org/repos/asf/inlong.git

commit 449d9321bcc4f4b8c465cf0da431ccfa507769f8
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Fri Dec 8 12:47:39 2023 +0800

    [INLONG-9444][Manager] ES sink unsuccessful flow status configuration 
successful (#9445)
    
    (cherry picked from commit 945987059dd1b58402ccc971d756080a7c2fdd58)
---
 .../resource/sink/AbstractStandaloneSinkResourceOperator.java      | 7 +++++++
 1 file changed, 7 insertions(+)

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 dd1c26d9f7..7a53035a23 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
@@ -19,6 +19,7 @@ package org.apache.inlong.manager.service.resource.sink;
 
 import org.apache.inlong.manager.common.consts.InlongConstants;
 import org.apache.inlong.manager.common.consts.SinkType;
+import org.apache.inlong.manager.common.enums.SinkStatus;
 import org.apache.inlong.manager.common.util.Preconditions;
 import org.apache.inlong.manager.dao.entity.InlongClusterEntity;
 import org.apache.inlong.manager.dao.entity.InlongGroupEntity;
@@ -27,6 +28,7 @@ import 
org.apache.inlong.manager.dao.mapper.InlongClusterEntityMapper;
 import org.apache.inlong.manager.dao.mapper.InlongGroupEntityMapper;
 import org.apache.inlong.manager.dao.mapper.StreamSinkEntityMapper;
 import org.apache.inlong.manager.pojo.sink.SinkInfo;
+import org.apache.inlong.manager.service.sink.StreamSinkService;
 
 import com.google.common.annotations.VisibleForTesting;
 import com.google.common.collect.Sets;
@@ -46,6 +48,8 @@ public abstract class AbstractStandaloneSinkResourceOperator 
implements SinkReso
     private StreamSinkEntityMapper sinkEntityMapper;
     @Autowired
     private InlongGroupEntityMapper groupEntityMapper;
+    @Autowired
+    private StreamSinkService sinkService;
 
     private static final String SORT_PREFIX = "SORT_";
 
@@ -54,6 +58,8 @@ public abstract class AbstractStandaloneSinkResourceOperator 
implements SinkReso
     @VisibleForTesting
     protected void assignCluster(SinkInfo sinkInfo) {
         if (StringUtils.isNotBlank(sinkInfo.getInlongClusterName())) {
+            String info = "success to create es resource";
+            sinkService.updateStatus(sinkInfo.getId(), 
SinkStatus.CONFIG_SUCCESSFUL.getCode(), info);
             return;
         }
 
@@ -65,6 +71,7 @@ public abstract class AbstractStandaloneSinkResourceOperator 
implements SinkReso
 
         StreamSinkEntity sink = 
sinkEntityMapper.selectByPrimaryKey(sinkInfo.getId());
         sink.setInlongClusterName(targetCluster);
+        sink.setStatus(SinkStatus.CONFIG_SUCCESSFUL.getCode());
         sinkEntityMapper.updateByIdSelective(sink);
     }