fix push data

FelixStarship · Apr 1, 2023 · 34ad6bc · 34ad6bc
1 parent c7c694e
commit 34ad6bc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pushgw/writer/writer.go b/pushgw/writer/writer.go
@@ -201,9 +201,9 @@ func (ws *WritersType) StartConsumer(identQueue *IdentQueue) {
 	for {
 		select {
 		case <-identQueue.closeCh:
+			logger.Infof("write queue:%v closed", identQueue)
 			return
 		default:
-			ws.sema.Acquire()
 			series := identQueue.list.PopBack(ws.pushgw.WriterOpt.QueuePopSize)
 			if len(series) == 0 {
 				time.Sleep(time.Millisecond * 400)