1.6.1

Author: qq254963746

lts-queue/lts-queue-mongo/src/main/java/com/lts/queue/mongo/MongoPreLoader.java

@@ -50,7 +50,7 @@ protected List<JobPo> load(String loadTaskTrackerNodeGroup, int offset) {
         Query<JobPo> query = template.createQuery(tableName, JobPo.class);
         query.field("isRunning").equal(false)
                 .filter("triggerTime < ", SystemClock.now())
-                .order(" triggerTime, priority , gmtCreated").offset(offset).limit(step);
+                .order(" triggerTime, priority , gmtCreated").offset(offset).limit(loadSize);
         return query.asList();
     }
 

lts-queue/lts-queue-mysql/src/main/java/com/lts/queue/mysql/MysqlPreLoader.java

@@ -59,7 +59,7 @@ protected List<JobPo> load(String loadTaskTrackerNodeGroup, int offset) {
             Long now = SystemClock.now();
             return sqlTemplate.query(getRealSql(takeSelectSQL, loadTaskTrackerNodeGroup),
                     ResultSetHandlerHolder.JOB_PO_LIST_RESULT_SET_HANDLER,
-                    false, now, offset, step);
+                    false, now, offset, loadSize);
         } catch (SQLException e) {
             return null;
         }