From 4810053142a202d4b9681da3d028de09b816fa0f Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Mon, 18 Mar 2024 21:43:22 +0800 Subject: [PATCH] opti:tmq --- source/dnode/mnode/impl/src/mndTopic.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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; }