From c7a407368afffd2ed28e18023e99c858dcfaf421 Mon Sep 17 00:00:00 2001
From: Haleygo <hui.wang@daocloud.io>
Date: Thu, 27 Apr 2023 15:22:42 +0800
Subject: [PATCH] lib/opentsdbhttp: fix a typo preventing from using
 writeconcurrencylimiter (#4208)

---
 lib/protoparser/opentsdbhttp/streamparser.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/protoparser/opentsdbhttp/streamparser.go b/lib/protoparser/opentsdbhttp/streamparser.go
index cfa0512a6..e200aaf49 100644
--- a/lib/protoparser/opentsdbhttp/streamparser.go
+++ b/lib/protoparser/opentsdbhttp/streamparser.go
@@ -32,7 +32,7 @@ var (
 func ParseStream(req *http.Request, callback func(rows []Row) error) error {
 	wcr := writeconcurrencylimiter.GetReader(req.Body)
 	defer writeconcurrencylimiter.PutReader(wcr)
-	r := io.Reader(req.Body)
+	r := io.Reader(wcr)
 
 	readCalls.Inc()
 	if req.Header.Get("Content-Encoding") == "gzip" {