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-10-18 16:08:22 +08:00
parent e9550a6b2c
commit 7a3f1afe68
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3436,7 +3436,7 @@ void streamScanOperatorDecode(void* pBuff, int32_t len, SStreamScanInfo* pInfo)
SDecoder decoder = {0}; SDecoder decoder = {0};
pDeCoder = &decoder; pDeCoder = &decoder;
tDecoderInit(pDeCoder, buf, tlen); tDecoderInit(pDeCoder, buf, tlen);
if (tStartDecode(&decoder) < 0) { if (tStartDecode(pDeCoder) < 0) {
lino = __LINE__; lino = __LINE__;
goto _end; goto _end;
} }
@ -4316,6 +4316,10 @@ void streamScanReloadState(SOperatorInfo* pOperator) {
SDecoder decoder = {0}; SDecoder decoder = {0};
pDeCoder = &decoder; pDeCoder = &decoder;
tDecoderInit(pDeCoder, pBuff, len); tDecoderInit(pDeCoder, pBuff, len);
if (tStartDecode(pDeCoder) < 0) {
lino = __LINE__;
goto _end;
}
int32_t winCode = pInfo->stateStore.updateInfoDeserialize(pDeCoder, pUpInfo); int32_t winCode = pInfo->stateStore.updateInfoDeserialize(pDeCoder, pUpInfo);
taosMemoryFree(pBuff); taosMemoryFree(pBuff);
if (winCode == TSDB_CODE_SUCCESS && pInfo->pUpdateInfo) { if (winCode == TSDB_CODE_SUCCESS && pInfo->pUpdateInfo) {