From 12fb38c2add41b241b9a183de26dff33430a07b2 Mon Sep 17 00:00:00 2001 From: lpcy <70789644+lpcy@users.noreply.github.com> Date: Fri, 23 Apr 2021 20:34:27 +0800 Subject: [PATCH] optimize alarm (#6816) --- .../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 675aa1fb4..09ef00319 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 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);