[fix] distributor: fix goroutine leak (#4238)

Signed-off-by: fuling <fuling.lgz@alibaba-inc.com>
grafana · Aug 31, 2021 · 6f78ffe · 6f78ffe
1 parent b36bc5a
commit 6f78ffe
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/pkg/distributor/distributor.go b/pkg/distributor/distributor.go
@@ -300,6 +300,14 @@ func (d *Distributor) Push(ctx context.Context, req *logproto.PushRequest) (*log
 	case <-tracker.done:
 		return &logproto.PushResponse{}, validationErr
 	case <-ctx.Done():
+		go func() {
+			select {
+			case <-tracker.err:
+				return
+			case <-tracker.done:
+				return
+			}
+		}()
 		return nil, ctx.Err()
 	}
 }