diff --git a/service-executor/service-executor-task/src/main/java/com/lanyuanxiaoyao/service/executor/task/functions/pulsar/ReadPulsarSource.java b/service-executor/service-executor-task/src/main/java/com/lanyuanxiaoyao/service/executor/task/functions/pulsar/ReadPulsarSource.java
index ecdd662..5a04146 100644
--- a/service-executor/service-executor-task/src/main/java/com/lanyuanxiaoyao/service/executor/task/functions/pulsar/ReadPulsarSource.java
+++ b/service-executor/service-executor-task/src/main/java/com/lanyuanxiaoyao/service/executor/task/functions/pulsar/ReadPulsarSource.java
@@ -27,7 +27,7 @@ import org.slf4j.LoggerFactory;
  */
 public class ReadPulsarSource implements Source<RecordView, ReadPulsarSplit, Collection<ReadPulsarSplit>>, ResultTypeQueryable<RecordView>, Serializable {
     private static final Logger logger = LoggerFactory.getLogger(ReadPulsarSource.class);
-    private static final Long TASK_GAP = TimeUnit.MINUTES.toMillis(60);
+    private static final Long TASK_GAP = TimeUnit.MINUTES.toMillis(30);
     private static final DateTimeFormatter FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS")
             .withLocale(Locale.CHINA)
             .withZone(ZoneId.systemDefault());