From 80fae0be380e8703bcb2716eeef372a590b4a5f1 Mon Sep 17 00:00:00 2001
From: v-zhangjc9 <v-zhangjc9.gd@chinatelecom.cn>
Date: Sun, 12 May 2024 17:42:22 +0800
Subject: [PATCH] =?UTF-8?q?perf(executor-task):=20pulsar=E6=A3=80=E7=B4=A2?=
 =?UTF-8?q?=E8=8C=83=E5=9B=B4=E7=BC=A9=E7=9F=AD=E5=88=B030=E5=88=86?=
 =?UTF-8?q?=E9=92=9F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

后面可以优化为根据数据量来推测间隔
---
 .../executor/task/functions/pulsar/ReadPulsarSource.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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());