diff --git a/core/core-backend/src/main/java/io/dataease/datasource/server/DatasourceTaskServer.java b/core/core-backend/src/main/java/io/dataease/datasource/server/DatasourceTaskServer.java
index d147caedef..426e185381 100644
--- a/core/core-backend/src/main/java/io/dataease/datasource/server/DatasourceTaskServer.java
+++ b/core/core-backend/src/main/java/io/dataease/datasource/server/DatasourceTaskServer.java
@@ -57,6 +57,7 @@ public class DatasourceTaskServer {
         queryWrapper.eq("ds_id", dsId);
         queryWrapper.eq("table_name", tableName);
         queryWrapper.orderByDesc("start_time");
+        queryWrapper.last("limit 1");
         List<CoreDatasourceTaskLog> logs = coreDatasourceTaskLogMapper.selectList(queryWrapper);
         if (!CollectionUtils.isEmpty(logs)) {
             return logs.get(0);
@@ -192,6 +193,14 @@ public class DatasourceTaskServer {
         datasourceTaskMapper.update(record, updateTaskWrapper);
     }
 
+    public void cleanLog() {
+        long expTime = Long.parseLong("30") * 24L * 3600L * 1000L;
+        long threshold = System.currentTimeMillis() - expTime;
+        QueryWrapper<CoreDatasourceTaskLog> queryWrapper = new QueryWrapper<>();
+        queryWrapper.lt("start_time", threshold);
+        coreDatasourceTaskLogMapper.delete(queryWrapper);
+    }
+
 
     public enum ScheduleType {
         CRON, RIGHTNOW, SIMPLE_CRON, MANUAL
diff --git a/core/core-backend/src/main/java/io/dataease/job/schedule/CleanScheduler.java b/core/core-backend/src/main/java/io/dataease/job/schedule/CleanScheduler.java
index d1c8ecc3f5..375548ba09 100644
--- a/core/core-backend/src/main/java/io/dataease/job/schedule/CleanScheduler.java
+++ b/core/core-backend/src/main/java/io/dataease/job/schedule/CleanScheduler.java
@@ -1,5 +1,6 @@
 package io.dataease.job.schedule;
 
+import io.dataease.datasource.server.DatasourceTaskServer;
 import io.dataease.exportCenter.manage.ExportCenterManage;
 import io.dataease.utils.LogUtil;
 import jakarta.annotation.Resource;
@@ -11,6 +12,8 @@ public class CleanScheduler {
 
     @Resource(name = "exportCenterManage")
     private ExportCenterManage exportCenterManage;
+    @Resource(name = "datasourceTaskServer")
+    private DatasourceTaskServer datasourceTaskServer;
 
     @Scheduled(cron = "0 0 0 * * ?")
     public void clean() {
@@ -18,4 +21,11 @@ public class CleanScheduler {
         exportCenterManage.cleanLog();
         LogUtil.info("Execute export file cleaner success");
     }
+
+    @Scheduled(cron = "0 0 0 * * ?")
+    public void cleanSyncLog() {
+        LogUtil.info("Start to clean sync log ...");
+        datasourceTaskServer.cleanLog();
+        LogUtil.info("End to clean sync log.");
+    }
 }
diff --git a/core/core-backend/src/main/resources/db/migration/V2.10.4__ddl.sql b/core/core-backend/src/main/resources/db/migration/V2.10.4__ddl.sql
new file mode 100644
index 0000000000..6ab0735d5f
--- /dev/null
+++ b/core/core-backend/src/main/resources/db/migration/V2.10.4__ddl.sql
@@ -0,0 +1 @@
+CREATE INDEX idx_dataset_table_task_log_A ON core_datasource_task_log(ds_id, table_name, start_time);