[skywalking] branch master updated: Add protect logic to TopN's topNWorkerReportCycle (#9599)

[kezhenxu94]

This is an automated email from the ASF dual-hosted git repository.

kezhenxu94 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/skywalking.git


The following commit(s) were added to refs/heads/master by this push:
     new 15dab2ed8e Add protect logic to TopN's topNWorkerReportCycle (#9599)
15dab2ed8e is described below

commit 15dab2ed8ee89d252948b8a5521930951f82567c
Author: 吴晟 Wu Sheng <wu.sh...@foxmail.com>
AuthorDate: Wed Sep 14 09:54:51 2022 +0800

    Add protect logic to TopN's topNWorkerReportCycle (#9599)
---
 .../oap/server/core/analysis/worker/TopNStreamProcessor.java  | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git 
a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/TopNStreamProcessor.java
 
b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/TopNStreamProcessor.java
index 26a8b373b9..4ba5496114 100644
--- 
a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/TopNStreamProcessor.java
+++ 
b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/TopNStreamProcessor.java
@@ -54,7 +54,6 @@ public class TopNStreamProcessor implements 
StreamProcessor<TopN> {
     @Getter
     private List<TopNWorker> persistentWorkers = new ArrayList<>();
     private Map<Class<? extends Record>, TopNWorker> workers = new HashMap<>();
-    @Setter
     @Getter
     private int topNWorkerReportCycle = 10;
     @Setter
@@ -65,6 +64,13 @@ public class TopNStreamProcessor implements 
StreamProcessor<TopN> {
         return PROCESSOR;
     }
 
+    public void setTopNWorkerReportCycle(final int topNWorkerReportCycle) {
+        if (topNWorkerReportCycle < 1) {
+            return;
+        }
+        this.topNWorkerReportCycle = topNWorkerReportCycle;
+    }
+
     @Override
     @SuppressWarnings("unchecked")
     public void create(ModuleDefineHolder moduleDefineHolder,
@@ -79,7 +85,8 @@ public class TopNStreamProcessor implements 
StreamProcessor<TopN> {
         IRecordDAO recordDAO;
         try {
             recordDAO = 
storageDAO.newRecordDao(builder.getDeclaredConstructor().newInstance());
-        } catch (InstantiationException | IllegalAccessException | 
NoSuchMethodException | InvocationTargetException e) {
+        } catch (InstantiationException | IllegalAccessException | 
NoSuchMethodException |
+                 InvocationTargetException e) {
             throw new UnexpectedException(
                 "Create " + stream.builder().getSimpleName() + " top n record 
DAO failure.", e);
         }