diff --git a/src/system/detail/src/vnodeShell.c b/src/system/detail/src/vnodeShell.c
index c473b4241db30929688c65b9f5b5a01f924fab4c..971622eaeb912b6987ae944c083e0ec9a251d955 100644
--- a/src/system/detail/src/vnodeShell.c
+++ b/src/system/detail/src/vnodeShell.c
@@ -483,9 +483,8 @@ void vnodeExecuteRetrieveReq(SSchedMsg *pSched) {
 
   pMsg += size;
 
-  // write the progress information of each meter to response
-  // this is required by subscriptions
-  if (pQInfo != NULL ) {
+  // write the progress information of each meter to response this is required by subscriptions
+  if (pQInfo != NULL && code == TSDB_CODE_SUCCESS) {
     if (pQInfo->pTableQuerySupporter != NULL && pQInfo->pTableQuerySupporter->pMeterSidExtInfo != NULL) {
       *((int32_t *)pMsg) = htonl(pQInfo->pTableQuerySupporter->numOfMeters);
       pMsg += sizeof(int32_t);