From 6397d7a81d53e45f32e4148489e95aeee3b0c52e Mon Sep 17 00:00:00 2001 From: 54liuyao <54liuyao> Date: Thu, 25 Jul 2024 10:41:50 +0800 Subject: [PATCH] fix issue --- source/libs/executor/src/scanoperator.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c index c8fa1cbbc0..8cb4bfeb2f 100644 --- a/source/libs/executor/src/scanoperator.c +++ b/source/libs/executor/src/scanoperator.c @@ -3521,8 +3521,8 @@ static int32_t doRawScanNext(SOperatorInfo* pOperator, SSDataBlock** ppRes) { void* metaBuff = POINTER_SHIFT(tBuf, sizeof(SMqRspHead)); SEncoder encoder = {0}; tEncoderInit(&encoder, metaBuff, len); - tempRes = tEncodeMqMetaRsp(&encoder, &tmpMetaRsp); - if (TSDB_CODE_SUCCESS != tempRes) { + int32_t tempLen = tEncodeMqMetaRsp(&encoder, &tmpMetaRsp); + if (tempLen < 0) { qError("tmqsnap tEncodeMqMetaRsp error"); tEncoderClear(&encoder); taosMemoryFreeClear(tBuf);