Skip to content

Commit 2fec990

Browse files
authored
Merge pull request #328 from irector2016/patch-3
修复--将已经正常完成的任务错误识别为死任务,并重新执行的问题
2 parents 05b13b3 + fb5590c commit 2fec990

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

lts-core/src/main/java/com/github/ltsopensource/queue/mysql/MysqlExecutingJobQueue.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ public List<JobPo> getDeadJobs(long deadline) {
6060
.all()
6161
.from()
6262
.table(getTableName())
63-
.where("gmt_created < ?", deadline)
63+
.where("gmt_modified < ?", deadline)
6464
.list(RshHolder.JOB_PO_LIST_RSH);
6565
}
6666

lts-jobtracker/src/main/java/com/github/ltsopensource/jobtracker/sender/JobSender.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ private List<JobPo> fetchJob(String taskTrackerNodeGroup, String taskTrackerIden
6868

6969
// IMPORTANT: 这里要先切换队列
7070
try {
71-
jobPo.setGmtModified(jobPo.getGmtCreated());
71+
jobPo.setGmtModified(SystemClock.now());
7272
appContext.getExecutingJobQueue().add(jobPo);
7373
} catch (DupEntryException e) {
7474
LOGGER.warn("ExecutingJobQueue already exist:" + JSON.toJSONString(jobPo));

0 commit comments

Comments
 (0)