[INLONG-5555][Manager] Fix mapper function name, remove redundant unque key

Author: woofyzhao

inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/StreamSourceEntityMapper.java

@@ -76,7 +76,7 @@ List<StreamSourceEntity> selectByStatusAndType(@Param("list") List<Integer> list
     /**
      * Query the tasks by the given status list and type List.
      */
-    List<StreamSourceEntity> selectTaskByAgentIpOrCluster(@Param("statusList") List<Integer> statusList,
+    List<StreamSourceEntity> selectByAgentIpOrCluster(@Param("statusList") List<Integer> statusList,
             @Param("sourceTypeList") List<String> sourceTypeList, @Param("agentIp") String agentIp,
             @Param("clusterName") String clusterName, @Param("limit") int limit);
 

inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java

@@ -212,7 +212,7 @@ private List<DataConfig> fetchFileTasks(TaskRequest taskRequest) {
         final String agentClusterName = taskRequest.getClusterName();
         final String uuid = taskRequest.getUuid();
         LOGGER.debug("file task query = {}", taskRequest);
-        List<StreamSourceEntity> sourceEntities = sourceMapper.selectTaskByAgentIpOrCluster(needAddStatusList,
+        List<StreamSourceEntity> sourceEntities = sourceMapper.selectByAgentIpOrCluster(needAddStatusList,
                 Lists.newArrayList(SourceType.FILE), agentIp, agentClusterName,TASK_FETCH_SIZE * 10);
         List<DataConfig> fileTasks = Lists.newArrayList();
         for (StreamSourceEntity sourceEntity : sourceEntities) {

inlong-manager/manager-test/src/main/resources/h2/apache_inlong_manager.sql

@@ -398,7 +398,7 @@ CREATE TABLE IF NOT EXISTS `stream_source`
     `create_time`         timestamp    NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT 'Create time',
     `modify_time`         timestamp    NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT 'Modify time',
     PRIMARY KEY (`id`),
-    UNIQUE KEY `unique_source_name` (`inlong_group_id`, `inlong_stream_id`, `source_name`, `is_deleted`),
+    KEY `group_stream_index` (`inlong_group_id`, `inlong_stream_id`, `is_deleted`),
     KEY `source_status_index` (`status`, `is_deleted`),
     KEY `source_agent_ip_index` (`agent_ip`, `is_deleted`)
 );

inlong-manager/manager-web/sql/apache_inlong_manager.sql

@@ -419,7 +419,7 @@ CREATE TABLE IF NOT EXISTS `stream_source`
     `create_time`         timestamp    NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT 'Create time',
     `modify_time`         timestamp    NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT 'Modify time',
     PRIMARY KEY (`id`),
-    UNIQUE KEY `unique_source_name` (`inlong_group_id`, `inlong_stream_id`, `source_name`, `is_deleted`),
+    KEY `group_stream_index` (`inlong_group_id`, `inlong_stream_id`, `is_deleted`),
     KEY `source_status_index` (`status`, `is_deleted`),
     KEY `source_agent_ip_index` (`agent_ip`, `is_deleted`)
 ) ENGINE = InnoDB