diff --git a/source/libs/transport/src/thttp.c b/source/libs/transport/src/thttp.c
index 41347907d1..e8f25f4545 100644
--- a/source/libs/transport/src/thttp.c
+++ b/source/libs/transport/src/thttp.c
@@ -859,7 +859,11 @@ int32_t taosSendRecvHttpReportWithQID(const char* server, const char* uri, uint1
 
 static void transHttpDestroyHandle(void* handle) { taosMemoryFree(handle); }
 
-static void transHttpDestroyRecvHandle(void* handle) { taosMemoryFree(handle); }
+static void transHttpDestroyRecvHandle(void* handle) {
+  SHttpRecvBuf* p = handle;
+  taosMemoryFree(p->pBuf);
+  taosMemoryFree(p);
+}
 
 int64_t transInitHttpChanImpl();
 
diff --git a/source/libs/transport/test/transUT2.cpp b/source/libs/transport/test/transUT2.cpp
index f8448a3b67..0d46e533ad 100644
--- a/source/libs/transport/test/transUT2.cpp
+++ b/source/libs/transport/test/transUT2.cpp
@@ -533,7 +533,14 @@ TEST_F(TransEnv, http) {
   STelemAddrMgmt mgt;
   taosTelemetryMgtInit(&mgt, "telemetry.tdengine.com");
   int32_t code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, "test", strlen("test"),HTTP_FLAT); 
+
   taosMsleep(10000);
+  code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, "test", strlen("test"),HTTP_FLAT);
+  for (int32_t i = 0; i < 10; i++) {
+    code = taosSendTelemReport(&mgt,tsTelemUri, tsTelemPort, "test", strlen("test"),HTTP_FLAT);
+    taosMsleep(10000);
+
+  }
   
   taosTelemetryDestroy(&mgt); 
 }