@@ -47,7 +47,7 @@ func PrepareTimeWindowProducerQueue() {
faultLabel = f(data)
if faultLabel != "" {
if !canCollect() {
- return
+ break
}
subscribersTimes[i] = time.Now()
c_log.GlobalLogger.Errorf("触发事件【%v】,开始采集。", faultLabel)