diff --git a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java
index 101d701..ed2497c 100644
--- a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java
+++ b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java
@@ -199,7 +199,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
                 log.info("执行紧急任务");
                 log.info("sql为{}",finalSql);
                 executeUrgently(() -> {
-                    selectAndAdd(finalDatabaseId, basicId, finalSql, tableId,newAndOldMap, finalFirstArray,two);
+                    selectAndAdd(finalDatabaseId, basicId, limitSelect, tableId,newAndOldMap, finalFirstArray,two);
                 });
             }
 
@@ -207,7 +207,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
                 log.info("执行高级任务");
                 log.info("sql为{}",finalSql);
                 executeHigh(() -> {
-                    selectAndAdd(finalDatabaseId, basicId, finalSql, tableId,newAndOldMap, finalFirstArray,two);
+                    selectAndAdd(finalDatabaseId, basicId, limitSelect, tableId,newAndOldMap, finalFirstArray,two);
                 });
             }
 
@@ -215,7 +215,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
                 log.info("执行中级任务");
                 log.info("sql为{}",finalSql);
                 executeMedium(() -> {
-                    selectAndAdd(finalDatabaseId, basicId, finalSql, tableId,newAndOldMap, finalFirstArray,two);
+                    selectAndAdd(finalDatabaseId, basicId, limitSelect, tableId,newAndOldMap, finalFirstArray,two);
                 });
             }
 
@@ -223,7 +223,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
                 log.info("执行低级任务");
                 log.info("sql为{}",finalSql);
                 executeLow(() -> {
-                    selectAndAdd(finalDatabaseId, basicId, finalSql, tableId,newAndOldMap, finalFirstArray,two);
+                    selectAndAdd(finalDatabaseId, basicId, limitSelect, tableId,newAndOldMap, finalFirstArray,two);
                 });
             }
         }