diff --git a/source/dnode/mnode/impl/src/mndTopic.c b/source/dnode/mnode/impl/src/mndTopic.c index ae76f3be31..4a0d58a32e 100644 --- a/source/dnode/mnode/impl/src/mndTopic.c +++ b/source/dnode/mnode/impl/src/mndTopic.c @@ -386,7 +386,7 @@ static int32_t sendCheckInfoToVnode(STrans *pTrans, SMnode *pMnode, SMqTopicObj SEncoder encoder; tEncoderInit(&encoder, abuf, len); code = tEncodeSTqCheckInfo(&encoder, &info); - if (code != 0) { + if (code < 0) { terrno = TSDB_CODE_OUT_OF_MEMORY; goto END; }