diff --git a/core/core-backend/src/main/java/io/dataease/job/schedule/DeTaskExecutor.java b/core/core-backend/src/main/java/io/dataease/job/schedule/DeTaskExecutor.java
index 80331d11c7..a034f919ad 100644
--- a/core/core-backend/src/main/java/io/dataease/job/schedule/DeTaskExecutor.java
+++ b/core/core-backend/src/main/java/io/dataease/job/schedule/DeTaskExecutor.java
@@ -49,7 +49,7 @@ public class DeTaskExecutor {
         scheduleManager.addOrUpdateCronJob(jobKey, triggerKey, DeXpackScheduleJob.class, cron, new Date(startTime), end, jobDataMap);
     }
 
-    public void addRetryTask(Long taskId, Integer retryLimit, Integer retryInterval) {
+    public void addRetryTask(Long taskId, Integer retryLimit, Integer retryInterval, Object retryParam) {
         long saltTime = 3000L;
         long interval = retryInterval == null ? 5L : retryInterval;
         long intervalMill = interval * 60000L;
@@ -65,6 +65,7 @@ public class DeTaskExecutor {
         JobDataMap jobDataMap = new JobDataMap();
         jobDataMap.put("taskId", taskId);
         jobDataMap.put(IS_RETRY_TASK, true);
+        jobDataMap.put("retryParam", retryParam);
         Date end = null;
         if (ObjectUtils.isNotEmpty(endTime)) end = new Date(endTime);
         scheduleManager.addOrUpdateCronJob(jobKey, triggerKey, DeXpackScheduleJob.class, cron, new Date(now), end, jobDataMap);
diff --git a/de-xpack b/de-xpack
index a166443c5d..4ff66b0edc 160000
--- a/de-xpack
+++ b/de-xpack
@@ -1 +1 @@
-Subproject commit a166443c5df60215573af63186b96638cfaf8008
+Subproject commit 4ff66b0edcbaee440b370dc6054500982300b9b1