third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: fatal bug when updating instance status of frequent task

Browse Source
This commit is contained in:
Echo009 2021-03-01 15:29:11 +08:00
parent 519d370445
commit 9a6047ad9c
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/instance/InstanceManager.java
View File

@ -82,6 +82,10 @@ public class InstanceManager {
InstanceStatus receivedInstanceStatus = InstanceStatus.of(req.getInstanceStatus()); InstanceStatus receivedInstanceStatus = InstanceStatus.of(req.getInstanceStatus());
Integer timeExpressionType = jobInfo.getTimeExpressionType(); Integer timeExpressionType = jobInfo.getTimeExpressionType();
instanceInfo.setStatus(receivedInstanceStatus.getV());
instanceInfo.setLastReportTime(req.getReportTime());
instanceInfo.setGmtModified(new Date());
// FREQUENT 任务没有失败重试机制，TaskTracker一直运行即可，只需要将存活信息同步到DB即可 // FREQUENT 任务没有失败重试机制，TaskTracker一直运行即可，只需要将存活信息同步到DB即可
// FREQUENT 任务的 newStatus 只有2中情况，一种是 RUNNING，一种是 FAILED（表示该机器 overload，需要重新选一台机器执行） // FREQUENT 任务的 newStatus 只有2中情况，一种是 RUNNING，一种是 FAILED（表示该机器 overload，需要重新选一台机器执行）
// 综上，直接把 status 和 runningNum 同步到DB即可 // 综上，直接把 status 和 runningNum 同步到DB即可
@ -97,9 +101,6 @@ public class InstanceManager {
// 这里不会存在并发问题 // 这里不会存在并发问题
instanceInfo.setRunningTimes(instanceInfo.getRunningTimes() + 1); instanceInfo.setRunningTimes(instanceInfo.getRunningTimes() + 1);
} }
instanceInfo.setStatus(receivedInstanceStatus.getV());
instanceInfo.setLastReportTime(req.getReportTime());
instanceInfo.setGmtModified(new Date());
boolean finished = false; boolean finished = false;
if (receivedInstanceStatus == InstanceStatus.SUCCEED) { if (receivedInstanceStatus == InstanceStatus.SUCCEED) {