Fail fast if SampleFamily is empty after MAL filter expression (#13608)

Author: weixiang1862

docs/en/changes/changes.md

@@ -9,6 +9,7 @@
 * Enhance the alarm kernel with recovered status notification capability
 * Fix BrowserWebVitalsPerfData `clsTime` to `cls` and make it double type.
 * Init `log-mal-rules` at module provider start stage to avoid re-init for every LAL.
+* Fail fast if SampleFamily is empty after MAL filter expression.
 
 #### UI
 * Fix the missing icon in new native trace view.

oap-server/analyzer/meter-analyzer/src/main/java/org/apache/skywalking/oap/meter/analyzer/Analyzer.java

@@ -129,6 +129,12 @@ public void analyse(final ImmutableMap<String, SampleFamily> sampleFamilies) {
         }
         if (filterExpression != null) {
             input = filterExpression.filter(input);
+            if (input.isEmpty()) {
+                if (log.isDebugEnabled()) {
+                    log.debug("{} is ignored due to mismatch of filter {}", expression, filterExpression);
+                }
+                return;
+            }
         }
         Result r = expression.run(input);
         if (!r.isSuccess()) {

oap-server/analyzer/meter-analyzer/src/main/java/org/apache/skywalking/oap/meter/analyzer/dsl/FilterExpression.java

@@ -20,12 +20,12 @@
 
 import groovy.lang.Closure;
 import groovy.lang.GroovyShell;
+import java.util.HashMap;
 import java.util.Map;
+import java.util.Objects;
 import lombok.ToString;
 import lombok.extern.slf4j.Slf4j;
 
-import static java.util.stream.Collectors.toMap;
-
 @Slf4j
 @ToString(of = {"literal"})
 public class FilterExpression {
@@ -42,10 +42,14 @@ public FilterExpression(final String literal) {
 
     public Map<String, SampleFamily> filter(final Map<String, SampleFamily> sampleFamilies) {
         try {
-            return sampleFamilies.entrySet().stream().collect(toMap(
-                Map.Entry::getKey,
-                it -> it.getValue().filter(filterClosure)
-            ));
+            Map<String, SampleFamily> result = new HashMap<>();
+            for (Map.Entry<String, SampleFamily> entry : sampleFamilies.entrySet()) {
+                SampleFamily afterFilter = entry.getValue().filter(filterClosure);
+                if (!Objects.equals(afterFilter, SampleFamily.EMPTY)) {
+                    result.put(entry.getKey(), afterFilter);
+                }
+            }
+            return result;
         } catch (Throwable t) {
             log.error("failed to run \"{}\"", literal, t);
         }