xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix issue

This commit is contained in:
54liuyao 2024-07-25 10:41:50 +08:00
parent ac7a968420
commit 6397d7a81d
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/executor/src/scanoperator.c
View File

@ -3521,8 +3521,8 @@ static int32_t doRawScanNext(SOperatorInfo* pOperator, SSDataBlock** ppRes) {
void* metaBuff = POINTER_SHIFT(tBuf, sizeof(SMqRspHead)); void* metaBuff = POINTER_SHIFT(tBuf, sizeof(SMqRspHead));
SEncoder encoder = {0}; SEncoder encoder = {0};
tEncoderInit(&encoder, metaBuff, len); tEncoderInit(&encoder, metaBuff, len);
tempRes = tEncodeMqMetaRsp(&encoder, &tmpMetaRsp); int32_t tempLen = tEncodeMqMetaRsp(&encoder, &tmpMetaRsp);
if (TSDB_CODE_SUCCESS != tempRes) { if (tempLen < 0) {
qError("tmqsnap tEncodeMqMetaRsp error"); qError("tmqsnap tEncodeMqMetaRsp error");
tEncoderClear(&encoder); tEncoderClear(&encoder);
taosMemoryFreeClear(tBuf); taosMemoryFreeClear(tBuf);