[INLONG-11163][Manager] Fix the problem of adding dataaddtask failed

fuweng11 · Sep 20, 2024 · a32281c · a32281c
1 parent 260a12d
commit a32281c
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...rvice/src/main/java/org/apache/inlong/manager/service/source/file/FileSourceOperator.java b/...rvice/src/main/java/org/apache/inlong/manager/service/source/file/FileSourceOperator.java
@@ -35,7 +35,6 @@
 import org.apache.inlong.manager.service.source.AbstractSourceOperator;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
-import org.apache.commons.collections.CollectionUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -114,7 +113,6 @@ public Integer addDataAddTask(DataAddTaskRequest request, String operator) {
         StreamSourceEntity sourceEntity = sourceMapper.selectById(request.getSourceId());
         try {
             List<StreamSourceEntity> dataAddTaskList = sourceMapper.selectByTaskMapId(sourceEntity.getId());
-            int dataAddTaskSize = CollectionUtils.isNotEmpty(dataAddTaskList) ? dataAddTaskList.size() : 0;
             FileSourceDTO dto = FileSourceDTO.getFromJson(sourceEntity.getExtParams());
             dto.setStartTime(sourceRequest.getStartTime());
             dto.setEndTime(sourceRequest.getEndTime());
@@ -125,7 +123,7 @@ public Integer addDataAddTask(DataAddTaskRequest request, String operator) {
                     CommonBeanUtils.copyProperties(sourceEntity, StreamSourceEntity::new);
             dataAddTaskEntity.setId(null);
             dataAddTaskEntity.setSourceName(
-                    sourceEntity.getSourceName() + "-" + (dataAddTaskSize + 1) + "-" + sourceEntity.getId());
+                    sourceEntity.getSourceName() + "-" + request.getAuditVersion() + "-" + sourceEntity.getId());
             dataAddTaskEntity.setExtParams(objectMapper.writeValueAsString(dto));
             dataAddTaskEntity.setTaskMapId(sourceEntity.getId());
             Integer id = sourceMapper.insert(dataAddTaskEntity);