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

apache · Jan 20, 2025 · a1dcddd · a1dcddd
1 parent a901300
commit a1dcddd
Show file tree

Hide file tree

Showing 5 changed files with 20 additions and 2 deletions.
diff --git a/...-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/dal/dao/IJobInstanceDao.java b/...-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);

diff --git a/...seatunnel-app/src/main/java/org/apache/seatunnel/app/dal/dao/impl/JobInstanceDaoImpl.java b/...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

diff --git a/...er/seatunnel-app/src/main/java/org/apache/seatunnel/app/dal/mapper/JobInstanceMapper.java b/...er/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);

diff --git a/...nnel-app/src/main/java/org/apache/seatunnel/app/service/impl/TaskInstanceServiceImpl.java b/...nnel-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)) {

diff --git a/...eatunnel-app/src/main/resources/org/apache/seatunnel/app/dal/mapper/JobInstanceMapper.xml b/...eatunnel-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>