[pinpoint-apm#11419] Adjust flush interval for node and link information

emeroad · Aug 27, 2024 · 9950871 · 9950871
1 parent dda79e5
commit 9950871
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 2 deletions.
diff --git a/collector/src/main/java/com/navercorp/pinpoint/collector/scheduler/AvgMaxLinkScheduler.java b/collector/src/main/java/com/navercorp/pinpoint/collector/scheduler/AvgMaxLinkScheduler.java
@@ -19,7 +19,10 @@
 
 import com.navercorp.pinpoint.collector.dao.CachedStatisticsDao;
 import jakarta.annotation.PostConstruct;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.TaskScheduler;
 import org.springframework.stereotype.Component;
 
@@ -30,20 +33,27 @@
 
 @Component
 public class AvgMaxLinkScheduler {
+    private final Logger logger = LogManager.getLogger(this.getClass());
 
     private final TaskScheduler scheduler;
     private final List<CachedStatisticsDao> statisticsDaoList;
+    private final Duration flushPeriod;
+
 
     public AvgMaxLinkScheduler(@Qualifier("statisticsLinkScheduler") TaskScheduler scheduler,
+                               @Value("${collector.map-link.avg.flush-period:5000}") Duration flushPeriod,
                                List<CachedStatisticsDao> statisticsDaoList) {
         this.scheduler = Objects.requireNonNull(scheduler, "scheduler");
         this.statisticsDaoList = Objects.requireNonNull(statisticsDaoList, "statisticsDaoList");
+        this.flushPeriod = Objects.requireNonNull(flushPeriod, "flushPeriod");
+        logger.info("AvgMaxLinkScheduler flushPeriod={}", flushPeriod);
+        logger.info("AvgMaxLinkScheduler CachedStatisticsDao:{}", statisticsDaoList);
     }
 
     @PostConstruct
     public void linkScheduling()  {
         for (CachedStatisticsDao dao : statisticsDaoList) {
-            this.scheduler.scheduleWithFixedDelay(dao::flushAvgMax, Duration.ofMillis(1000));
+            this.scheduler.scheduleWithFixedDelay(dao::flushAvgMax, flushPeriod);
         }
     }
 }
diff --git a/...tor/src/main/java/com/navercorp/pinpoint/collector/scheduler/StatisticsLinkScheduler.java b/...tor/src/main/java/com/navercorp/pinpoint/collector/scheduler/StatisticsLinkScheduler.java
@@ -19,7 +19,10 @@
 
 import com.navercorp.pinpoint.collector.dao.CachedStatisticsDao;
 import jakarta.annotation.PostConstruct;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.TaskScheduler;
 import org.springframework.stereotype.Component;
 
@@ -30,20 +33,26 @@
 
 @Component
 public class StatisticsLinkScheduler {
+    private final Logger logger = LogManager.getLogger(this.getClass());
 
     private final TaskScheduler scheduler;
     private final List<CachedStatisticsDao> statisticsDaoList;
+    private final Duration flushPeriod;
 
     public StatisticsLinkScheduler(@Qualifier("avgMaxLinkScheduler") TaskScheduler scheduler,
+                                   @Value("${collector.map-link.stat.flush-period:5000}") Duration flushPeriod,
                                    List<CachedStatisticsDao> statisticsDaoList) {
         this.scheduler = Objects.requireNonNull(scheduler, "scheduler");
         this.statisticsDaoList = Objects.requireNonNull(statisticsDaoList, "statisticsDaoList");
+        this.flushPeriod = Objects.requireNonNull(flushPeriod, "flushPeriod");
+        logger.info("StatisticsLinkScheduler flushPeriod={}", flushPeriod);
+        logger.info("StatisticsLinkScheduler CachedStatisticsDao:{}", statisticsDaoList);
     }
 
     @PostConstruct
     public void linkScheduling()  {
         for (CachedStatisticsDao dao : statisticsDaoList) {
-            this.scheduler.scheduleWithFixedDelay(dao::flushLink, Duration.ofMillis(1000));
+            this.scheduler.scheduleWithFixedDelay(dao::flushLink, flushPeriod);
         }
     }
 }