Update MysqlExecutingJobQueue.java

helango-seabiscuit · Jan 19, 2017 · c2175c5 · c2175c5
1 parent 05b13b3
commit c2175c5
Showing 1 changed file with 1 addition and 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
@@ -60,7 +60,7 @@ public List<JobPo> getDeadJobs(long deadline) {
                 .all()
                 .from()
                 .table(getTableName())
-                .where("gmt_created < ?", deadline)
+                .where("gmt_modified < ?", deadline)
                 .list(RshHolder.JOB_PO_LIST_RSH);
     }