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

fix ci issue

This commit is contained in:
54liuyao 2024-10-09 10:07:39 +08:00
parent 1353614dc2
commit 67237ae615
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/libs/executor/src/streamtimesliceoperator.c
View File

@ -1662,7 +1662,8 @@ static int32_t doDeleteTimeSliceResult(SStreamAggSupporter* pAggSup, SSDataBlock
if (key.ts > endCalTs) {
break;
}
(void)tSimpleHashRemove(pUpdatedMap, &key, sizeof(SWinKey));
int32_t tmpRes = tSimpleHashRemove(pUpdatedMap, &key, sizeof(SWinKey));
qTrace("delete stream interp result at line %d res: %s", __func__, __LINE__, tstrerror(tmpRes));
pAggSup->stateStore.streamStateDel(pAggSup->pState, &key);
if (winCode != TSDB_CODE_SUCCESS) {