You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2021/04/23 12:34:58 UTC
[skywalking] branch master updated: optimize alarm (#6816)
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 <70...@users.noreply.github.com>
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);