diff --git a/src/dnode/src/dnodeVRead.c b/src/dnode/src/dnodeVRead.c index cdb03de5558ce82d9e45a690c012fec3fea19c2a..9dac65c7659fe04b402359d44f98a42bc94f1612 100644 --- a/src/dnode/src/dnodeVRead.c +++ b/src/dnode/src/dnodeVRead.c @@ -214,7 +214,7 @@ static void *dnodeProcessReadQueue(void *param) { if (code == TSDB_CODE_QRY_HAS_RSP) { dnodeSendRpcReadRsp(pVnode, pReadMsg, pReadMsg->rpcMsg.code); } else { // code == TSDB_CODE_QRY_NOT_READY, do not return msg to client - assert(pReadMsg->rpcMsg.handle != NULL); + assert(pReadMsg->rpcMsg.handle == NULL); dnodeDispatchNonRspMsg(pVnode, pReadMsg, code); } }