fix: alert compute await (#700)

traas-stack · Oct 18, 2023 · 47a49e8 · 47a49e8
1 parent 2a61af9
commit 47a49e8
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/...home/home-alert/src/main/java/io/holoinsight/server/home/alert/common/http/HttpProxy.java b/...home/home-alert/src/main/java/io/holoinsight/server/home/alert/common/http/HttpProxy.java
@@ -10,6 +10,7 @@
 import java.util.Map;
 import java.util.UUID;
 import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
 
 /**
  * http DataCollection proxy
@@ -149,7 +150,7 @@ public void handle(XHttpResponse rep) {
         latch.countDown();
       }
     });
-    latch.await();
+    latch.await(30, TimeUnit.SECONDS);
     if (optional.sucess) {
       logger.info("http request[" + request + "] cost " + (System.currentTimeMillis() - start)
           + "ms, code[" + optional.response.code + "].");

diff --git a/...io/holoinsight/server/home/alert/service/calculate/AbstractUniformInspectRunningRule.java b/...io/holoinsight/server/home/alert/service/calculate/AbstractUniformInspectRunningRule.java
@@ -172,7 +172,7 @@ public EventInfo runRule(InspectConfig inspectConfig, long period,
           }
         });
       }
-      latch.await();
+      latch.await(30, TimeUnit.SECONDS);
       if (triggerResults.size() != 0) {
         triggerMap.put(trigger, triggerResults);
       }

diff --git a/...rt/src/main/java/io/holoinsight/server/home/alert/service/calculate/AlertTaskCompute.java b/...rt/src/main/java/io/holoinsight/server/home/alert/service/calculate/AlertTaskCompute.java
@@ -197,7 +197,7 @@ protected List<EventInfo> calculate(ComputeTaskPackage computeTaskPackage) {
         RecordSucOrFailNotify.alertNotifyProcessSuc(ALERT_TASK_COMPUTE, "alert task compute",
             inspectConfig.getAlertNotifyRecord());
       }
-      latch.await();
+      latch.await(30, TimeUnit.SECONDS);
       if (!CollectionUtils.isEmpty(alertNotifyRecordDTOList)) {
         RecordSucOrFailNotify.batchInsert(alertNotifyRecordDTOList);
       }