diff --git a/source/libs/stream/src/streamState.c b/source/libs/stream/src/streamState.c
index 26904ebbfb5a2ea720be8eea1ee08c67b963eb57..9e61e8aacac3d263d01d68216f9783df58dd9d4f 100644
--- a/source/libs/stream/src/streamState.c
+++ b/source/libs/stream/src/streamState.c
@@ -140,7 +140,7 @@ SStreamState* streamStateOpen(char* path, void* pTask, bool specPath, int32_t sz
     pState->pTdbState->pBackendCfWrapper = taosAcquireRef(streamBackendCfWrapperId, id);
     // already exist stream task for
     qInfo("already exist stream state for %s", pState->pTdbState->idstr);
-    taosAcquireRef(streamBackendId, pState->streamBackendRid);
+    // taosAcquireRef(streamBackendId, pState->streamBackendRid);
   }
   taosThreadMutexUnlock(&pMeta->backendMutex);
 
diff --git a/source/libs/transport/src/transSvr.c b/source/libs/transport/src/transSvr.c
index c6c412022a001487b9f50939c3c6a0c6b2de6844..e16c490fee28a39800ec6b76eaed8962045ecb37 100644
--- a/source/libs/transport/src/transSvr.c
+++ b/source/libs/transport/src/transSvr.c
@@ -196,8 +196,6 @@ static bool uvHandleReq(SSvrConn* pConn) {
     tError("%s conn %p recv invalid packet, failed to decompress", transLabel(pTransInst), pConn);
     return false;
   }
-  tDebug("head version: %d 2", pHead->version);
-
   pHead->code = htonl(pHead->code);
   pHead->msgLen = htonl(pHead->msgLen);