bug fix

ltsopensource · Apr 15, 2016 · 35d8d3f · 35d8d3f
1 parent d90fb09
commit 35d8d3f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lts-core/src/main/java/com/lts/queue/mongo/MongoSchedulerJobQueue.java b/lts-core/src/main/java/com/lts/queue/mongo/MongoSchedulerJobQueue.java
@@ -37,7 +37,7 @@ public boolean updateLastGenerateTriggerTime(String jobId, Long lastGenerateTrig
     @Override
     public List<JobPo> getNeedGenerateJobPos(Long checkTime, int topSize) {
         Query<JobPo> query = template.createQuery(JobPo.class);
-        query.field("relyOnPrevCycle").equal(true);
+        query.field("relyOnPrevCycle").equal(false);
         query.field("lastGenerateTriggerTime").equal(checkTime);
         query.offset(0).limit(topSize);
         return query.asList();