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);