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

fix(stream):fix bloom filter decode issue

This commit is contained in:
54liuyao 2024-11-13 19:37:22 +08:00
parent 2e3196cfdc
commit 87e1f8da47
1 changed files with 15 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3465,11 +3465,6 @@ void streamScanOperatorDecode(void* pBuff, int32_t len, SStreamScanInfo* pInfo)
goto _end; goto _end;
} }
void* pUpInfo = taosMemoryCalloc(1, sizeof(SUpdateInfo));
if (!pUpInfo) {
lino = __LINE__;
goto _end;
}
SDecoder decoder = {0}; SDecoder decoder = {0};
pDeCoder = &decoder; pDeCoder = &decoder;
tDecoderInit(pDeCoder, buf, tlen); tDecoderInit(pDeCoder, buf, tlen);
@ -3478,14 +3473,21 @@ void streamScanOperatorDecode(void* pBuff, int32_t len, SStreamScanInfo* pInfo)
goto _end; goto _end;
} }
code = pInfo->stateStore.updateInfoDeserialize(pDeCoder, pUpInfo); if (pInfo->pUpdateInfo != NULL) {
if (code == TSDB_CODE_SUCCESS) { void* pUpInfo = taosMemoryCalloc(1, sizeof(SUpdateInfo));
pInfo->stateStore.updateInfoDestroy(pInfo->pUpdateInfo); if (!pUpInfo) {
pInfo->pUpdateInfo = pUpInfo; lino = __LINE__;
} else { goto _end;
taosMemoryFree(pUpInfo); }
lino = __LINE__; code = pInfo->stateStore.updateInfoDeserialize(pDeCoder, pUpInfo);
goto _end; if (code == TSDB_CODE_SUCCESS) {
pInfo->stateStore.updateInfoDestroy(pInfo->pUpdateInfo);
pInfo->pUpdateInfo = pUpInfo;
} else {
taosMemoryFree(pUpInfo);
lino = __LINE__;
goto _end;
}
} }
if (tDecodeIsEnd(pDeCoder)) { if (tDecodeIsEnd(pDeCoder)) {