diff --git a/src/dnode/src/dnodeVRead.c b/src/dnode/src/dnodeVRead.c
index bbea1a5e0bb52a56cfbf5a23dd29a17e094586a9..ebbad525dd61bb79e7b105ce17890245c25a8fba 100644
--- a/src/dnode/src/dnodeVRead.c
+++ b/src/dnode/src/dnodeVRead.c
@@ -206,7 +206,7 @@ static void *dnodeProcessReadQueue(void *param) {
            taosMsg[pReadMsg->rpcMsg.msgType], type);
     int32_t code = vnodeProcessRead(pVnode, pReadMsg);
 
-    if (type == TAOS_QTYPE_RPC) {
+    if (type == TAOS_QTYPE_RPC && code != TSDB_CODE_QRY_NOT_READY) {
       dnodeSendRpcReadRsp(pVnode, pReadMsg, code);
     } else {
       dnodeDispatchNonRspMsg(pVnode, pReadMsg, code);
diff --git a/src/inc/taoserror.h b/src/inc/taoserror.h
index 59b2c0220b8206f5b302f1274902f7816b747043..5a49f24804c09332584352d55aea9d5a143b24ec 100644
--- a/src/inc/taoserror.h
+++ b/src/inc/taoserror.h
@@ -210,6 +210,7 @@ TAOS_DEFINE_ERROR(TSDB_CODE_QRY_OUT_OF_MEMORY,            0, 0x0703, "query out
 TAOS_DEFINE_ERROR(TSDB_CODE_QRY_APP_ERROR,                0, 0x0704, "query app error")
 TAOS_DEFINE_ERROR(TSDB_CODE_QRY_DUP_JOIN_KEY,             0, 0x0705, "query duplicated join key")
 TAOS_DEFINE_ERROR(TSDB_CODE_QRY_EXCEED_TAGS_LIMIT,        0, 0x0706, "query tag conditon too many")
+TAOS_DEFINE_ERROR(TSDB_CODE_QRY_NOT_READY,                0, 0x0707, "query not ready")
 
 // grant
 TAOS_DEFINE_ERROR(TSDB_CODE_GRANT_EXPIRED,                0, 0x0800, "grant expired")