Fix ticket event missing bug (#82)

* Fix ticket event missing bug

* notes

Author: liuhaoyang

analyzer-alert/src/main/java/cloud/erda/analyzer/alert/Main.java

@@ -161,17 +161,12 @@ public static void main(String[] args) throws Exception {
                 .setParallelism(parameterTool.getInt(STREAM_PARALLELISM_OPERATOR))
                 .name("broadcast alert notify");
 
-        DataStream<AlertEvent> levelMatchedAlertEventsWithNotify = alertEventsWithNotify
-                .filter(new AlertEventLevelFilterFunction())
-                .setParallelism(parameterTool.getInt(STREAM_PARALLELISM_OPERATOR))
-                .name("filter event notify level");
-
         DataStream<NotifyEvent> notifyEventWithTemplate = notifyEventDataStream.connect(allUniversalTemplates.broadcast(StateDescriptors.notifyTemplate))
                 .process(new NotifyTemplateProcessFunction(parameterTool.getLong(METRIC_METADATA_TTL, 7500), StateDescriptors.notifyTemplate))
                 .setParallelism(parameterTool.getInt(STREAM_PARALLELISM_OPERATOR))
                 .name("notify event with template");
 
-        DataStream<AlertEvent> alertEventsWithTemplate = levelMatchedAlertEventsWithNotify
+        DataStream<AlertEvent> alertEventsWithTemplate = alertEventsWithNotify
                 .connect(alertNotifyTemplateQuery.union(alertNotifyCustomTemplateQuery).broadcast(StateDescriptors.alertNotifyTemplateStateDescriptor))
                 .process(new AlertNotifyTemplateBroadcastProcessFunction(parameterTool.getLong(METRIC_METADATA_TTL,
                         75000), StateDescriptors.alertNotifyTemplateStateDescriptor))
@@ -243,6 +238,9 @@ public static void main(String[] args) throws Exception {
         }
 
         DataStream<AlertEvent> alertEventLevel = alertEventsWithTemplate
+                .filter(new AlertEventLevelFilterFunction())
+                .setParallelism(parameterTool.getInt(STREAM_PARALLELISM_OPERATOR))
+                .name("filter event notify level")
                 .assignTimestampsAndWatermarks(new AlertEventWatermarkExtractor())
                 .keyBy(new AlertEventGroupFunction())
                 .window(TumblingProcessingTimeWindows.of(Time.seconds(15)))

analyzer-alert/src/main/java/cloud/erda/analyzer/alert/functions/AlertEventLevelFilterFunction.java

@@ -14,9 +14,9 @@ public boolean filter(AlertEvent alertEvent) throws Exception {
         AlertLevel eventLevel = alertEvent.getLevel();
         AlertLevel[] notifyLevels = alertEvent.getAlertNotify().getNotifyTarget().getLevels();
 
-        // compatible only when the get level fails (AlertLevel.UNKNOWN) and the notifyGroup's level is empty
-        if (AlertLevel.UNKNOWN.equals(eventLevel)) {
-            return notifyLevels.length == 0;
+        // compatible only when the get level fails (AlertLevel.UNKNOWN) or the notifyGroup's level is empty
+        if (AlertLevel.UNKNOWN.equals(eventLevel) || notifyLevels.length == 0) {
+            return true;
         }
 
         for (AlertLevel notifyLevel : notifyLevels) {

erda.yml

@@ -21,7 +21,8 @@ envs:
   TASK_MANAGER_MEMORY_MANAGED_FRACTION: "0.3"
   TASK_MANAGER_MEMORY_JVM_METASPACE_SIZE: "256M"
   TASK_MANAGER_JVM_EXIT_OOM: "true"
-  FLINK_ENV_JAVA_OPTS_TM: "-XX:+UseG1GC -XX:+TraceClassLoading -XX:+TraceClassUnloading -XX:+PrintGC -XX:+PrintGCDetails"
+#  FLINK_ENV_JAVA_OPTS_TM: "-XX:+UseG1GC -XX:+TraceClassLoading -XX:+TraceClassUnloading -XX:+PrintGC -XX:+PrintGCDetails"
+  FLINK_ENV_JAVA_OPTS_TM: "-XX:+UseG1GC -XX:+PrintGC -XX:+PrintGCDetails"
   MONITOR_ADDR: "monitor:7096"
   EVENTBOX_ADDR: "eventbox:9528"
   ANALYZER_METRICS_ADDR: "analyzer-metrics:8081"