过滤 120s 以前的 trace，不进行分析

@@ -40,9 +40,15 @@ public class TraceAnalyzeFlinkHandler implements TraceFlinkHandler,Serializable
             public void flatMap(Spans spans, Collector<Tuple2<String, SpanInfo>> collector) throws Exception {
                 List<Span> list = spans.getSpans();
                 Iterator<Span> itor = list.iterator();
+                long current = System.currentTimeMillis();
                 while (itor.hasNext()) {
                     Span span = itor.next();
 
+                    //过滤 120s 以前的 trace，不进行分析
+                    if (current - span.getEnd() >= 120000) {
+                        return;
+                    }
+
                     String logEvent = "none";
                     if (CollectionUtils.isNotEmpty(span.logs())) {
                         logEvent = span.logs().get(0).getEvent();