From c2175c59c50014ad7c266ec6102bca50ea13ea41 Mon Sep 17 00:00:00 2001 From: irector2016 <85151441@qq.com> Date: Thu, 19 Jan 2017 19:14:10 +0800 Subject: [PATCH] Update MysqlExecutingJobQueue.java --- .../ltsopensource/queue/mysql/MysqlExecutingJobQueue.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lts-core/src/main/java/com/github/ltsopensource/queue/mysql/MysqlExecutingJobQueue.java b/lts-core/src/main/java/com/github/ltsopensource/queue/mysql/MysqlExecutingJobQueue.java index 5b125b580..cadd7b2b2 100644 --- a/lts-core/src/main/java/com/github/ltsopensource/queue/mysql/MysqlExecutingJobQueue.java +++ b/lts-core/src/main/java/com/github/ltsopensource/queue/mysql/MysqlExecutingJobQueue.java @@ -60,7 +60,7 @@ public List getDeadJobs(long deadline) { .all() .from() .table(getTableName()) - .where("gmt_created < ?", deadline) + .where("gmt_modified < ?", deadline) .list(RshHolder.JOB_PO_LIST_RSH); }