This is an automated email from the ASF dual-hosted git repository.
zirui 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 945987059d [INLONG-9444][Manager] ES sink unsuccessful flow status
configuration successful (#9445)
945987059d is described below
commit 945987059dd1b58402ccc971d756080a7c2fdd58
Author: fuweng11 <[email protected]>
AuthorDate: Fri Dec 8 12:47:39 2023 +0800
[INLONG-9444][Manager] ES sink unsuccessful flow status configuration
successful (#9445)
---
.../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);
}