diff --git a/src/system/detail/src/vnodeShell.c b/src/system/detail/src/vnodeShell.c
index 6e43e7074243ba8480c4781139c14c50e311eeb4..3cf1c91ee2ab9e022e85ce6f36886dc2a00ac9ee 100644
--- a/src/system/detail/src/vnodeShell.c
+++ b/src/system/detail/src/vnodeShell.c
@@ -485,7 +485,7 @@ void vnodeExecuteRetrieveReq(SSchedMsg *pSched) {
 
   // write the progress information of each meter to response
   // this is required by subscriptions
-  if (numOfRows > 0 && code == TSDB_CODE_SUCCESS) {
+  if (pQInfo != NULL ) {
     if (pQInfo->pMeterQuerySupporter != NULL && pQInfo->pMeterQuerySupporter->pMeterSidExtInfo != NULL) {
       *((int32_t *)pMsg) = htonl(pQInfo->pMeterQuerySupporter->numOfMeters);
       pMsg += sizeof(int32_t);