[Bug] Task instance filter by execution user is not working

Author: arshadmohammad

seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/dal/dao/IJobInstanceDao.java

@@ -45,6 +45,8 @@ IPage<SeaTunnelJobInstanceDto> queryJobInstanceListPaging(
             Date startTime,
             Date endTime,
             String jobDefineId,
+            String executorName,
+            String stateType,
             JobMode jobMode);
 
     List<JobInstance> getAllJobInstance(@NonNull List<Long> jobInstanceIdList);

seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/dal/dao/impl/JobInstanceDaoImpl.java

@@ -72,9 +72,11 @@ public IPage<SeaTunnelJobInstanceDto> queryJobInstanceListPaging(
             Date startTime,
             Date endTime,
             String jobDefineName,
+            String executorName,
+            String stateType,
             JobMode jobMode) {
         return jobInstanceMapper.queryJobInstanceListPaging(
-                page, startTime, endTime, jobDefineName, jobMode);
+                page, startTime, endTime, jobDefineName, executorName, stateType, jobMode);
     }
 
     @Override

seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/dal/mapper/JobInstanceMapper.java

@@ -37,6 +37,8 @@ IPage<SeaTunnelJobInstanceDto> queryJobInstanceListPaging(
             @Param("startTime") Date startTime,
             @Param("endTime") Date endTime,
             @Param("jobDefineName") String jobDefineName,
+            @Param("executorName") String executorName,
+            @Param("stateType") String stateType,
             @Param("jobMode") JobMode jobMode);
 
     JobInstance getJobExecutionStatus(@Param("jobInstanceId") Long jobInstanceId);

seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/service/impl/TaskInstanceServiceImpl.java

@@ -86,7 +86,13 @@ public Result<PageInfo<SeaTunnelJobInstanceDto>> getSyncTaskInstancePaging(
 
         IPage<SeaTunnelJobInstanceDto> jobInstanceIPage =
                 jobInstanceDao.queryJobInstanceListPaging(
-                        new Page<>(pageNo, pageSize), startDate, endDate, jobDefineName, jobMode);
+                        new Page<>(pageNo, pageSize),
+                        startDate,
+                        endDate,
+                        jobDefineName,
+                        executorName,
+                        stateType,
+                        jobMode);
 
         List<SeaTunnelJobInstanceDto> records = jobInstanceIPage.getRecords();
         if (CollectionUtils.isEmpty(records)) {

seatunnel-server/seatunnel-app/src/main/resources/org/apache/seatunnel/app/dal/mapper/JobInstanceMapper.xml

@@ -49,6 +49,12 @@
             <if test="jobDefineName != null">
                 AND jd.name LIKE concat('%', #{jobDefineName}, '%')
             </if>
+            <if test="executorName != null">
+                AND cu.username LIKE concat('%', #{executorName}, '%')
+            </if>
+            <if test="stateType != null">
+                AND ji.job_status LIKE concat('%', #{stateType}, '%')
+            </if>
             <if test="jobMode != null">
                 AND ji.job_type = #{jobMode}
             </if>