diff --git a/src/vnode/src/vnodeRead.c b/src/vnode/src/vnodeRead.c
index 83986de682..2586a2db99 100644
--- a/src/vnode/src/vnodeRead.c
+++ b/src/vnode/src/vnodeRead.c
@@ -236,6 +236,7 @@ static int32_t vnodeProcessFetchMsg(SVnodeObj *pVnode, SReadMsg *pReadMsg) {
         freeHandle = false;
       } else {
         qKillQuery(*handle);
+        qDestroyQueryInfo(*handle);
         freeHandle = true;
       }
     }