diff --git a/dinky-admin/src/main/java/org/dinky/service/impl/JobInstanceServiceImpl.java b/dinky-admin/src/main/java/org/dinky/service/impl/JobInstanceServiceImpl.java index 0de903ed38..fcb2f2fcc2 100644 --- a/dinky-admin/src/main/java/org/dinky/service/impl/JobInstanceServiceImpl.java +++ b/dinky-admin/src/main/java/org/dinky/service/impl/JobInstanceServiceImpl.java @@ -220,7 +220,11 @@ public JobInfoDetail refreshJobInfoDetail(Integer jobInstanceId, boolean isForce @Override public boolean hookJobDone(String jobId, Integer taskId) { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); - queryWrapper.eq(JobInstance::getJid, jobId).eq(JobInstance::getTaskId, taskId); + queryWrapper + .eq(JobInstance::getJid, jobId) + .eq(JobInstance::getTaskId, taskId) + .orderByDesc(JobInstance::getCreateTime) + .last("limit 1"); JobInstance instance = baseMapper.selectOne(queryWrapper); if (instance == null) { // Not having a corresponding jobinstance means that this may not have succeeded in running,