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