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

wusheng 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 12fb38c  optimize alarm (#6816)
12fb38c is described below

commit 12fb38c2add41b241b9a183de26dff33430a07b2
Author: lpcy <[email protected]>
AuthorDate: Fri Apr 23 20:34:27 2021 +0800

    optimize alarm (#6816)
---
 .../apache/skywalking/oap/server/core/alarm/provider/AlarmCore.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/oap-server/server-alarm-plugin/src/main/java/org/apache/skywalking/oap/server/core/alarm/provider/AlarmCore.java
 
b/oap-server/server-alarm-plugin/src/main/java/org/apache/skywalking/oap/server/core/alarm/provider/AlarmCore.java
index 675aa1f..09ef003 100644
--- 
a/oap-server/server-alarm-plugin/src/main/java/org/apache/skywalking/oap/server/core/alarm/provider/AlarmCore.java
+++ 
b/oap-server/server-alarm-plugin/src/main/java/org/apache/skywalking/oap/server/core/alarm/provider/AlarmCore.java
@@ -81,7 +81,9 @@ public class AlarmCore {
                         alarmMessageList.addAll(messages);
                     }
                     List<AlarmMessage> filteredMessages = 
alarmMessageList.stream().filter(msg -> 
!msg.isOnlyAsCondition()).collect(Collectors.toList());
-                    allCallbacks.forEach(callback -> 
callback.doAlarm(filteredMessages));
+                    if (filteredMessages.size() > 0) {
+                        allCallbacks.forEach(callback -> 
callback.doAlarm(filteredMessages));
+                    }
                 }
             } catch (Exception e) {
                 LOGGER.error(e.getMessage(), e);

Reply via email to