kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

optimize alarm (#6816)

This commit is contained in:
lpcy 2021-04-23 20:34:27 +08:00 committed by GitHub
parent 10e89aa566
commit 12fb38c2ad
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
oap-server/server-alarm-plugin/src/main/java/org/apache/skywalking/oap/server/core/alarm/provider/AlarmCore.java
View File

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