|
@@ -33,8 +33,8 @@ outLoop:
|
|
|
}
|
|
|
|
|
|
waitLength := len(global.TimeWindowConsumerQueue)
|
|
|
- log.GlobalLogger.Infof("待处理窗口个数为:%v", len(global.TimeWindowConsumerQueue))
|
|
|
if waitLength > 0 {
|
|
|
+ log.GlobalLogger.Infof("待处理窗口个数为:%v", len(global.TimeWindowConsumerQueue))
|
|
|
// 1 获取即将处理的窗口
|
|
|
currentTimeWindow := global.TimeWindowConsumerQueue[0]
|
|
|
util.RemoveHeaOfdTimeWindowConsumerQueue()
|