|
@@ -32,7 +32,7 @@ func RunTimeWindowProducerQueue() {
|
|
|
// 处理
|
|
|
time.Sleep(time.Duration(1) * time.Second)
|
|
|
if len(global.TimeWindowProducerQueue) > 0 {
|
|
|
- bags := util2.ListAbsolutePathWithSuffixAndSort(commonConfig.CloudConfig.BagDataDir, ".bag")
|
|
|
+ bags, _ := util2.ListAbsolutePathWithSuffixAndSort(commonConfig.CloudConfig.BagDataDir, ".bag")
|
|
|
currentTimeWindow := global.TimeWindowProducerQueue[0]
|
|
|
move := false
|
|
|
bigger := false
|