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

adj stream op result

This commit is contained in:
54liuyao 2024-07-19 14:50:31 +08:00
parent 5b293e7340
commit 6a71994570
4 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -55,13 +55,13 @@ void destroyStreamCountAggOperatorInfo(void* param) {
pInfo->pUpdated = NULL;
colDataDestroy(&pInfo->twAggSup.timeWindowData);
pInfo->pDelRes = blockDataDestroy(pInfo->pDelRes);
blockDataDestroy(pInfo->pDelRes);
tSimpleHashCleanup(pInfo->pStUpdated);
tSimpleHashCleanup(pInfo->pStDeleted);
cleanupGroupResInfo(&pInfo->groupResInfo);
taosArrayDestroy(pInfo->historyWins);
pInfo->pCheckpointRes = blockDataDestroy(pInfo->pCheckpointRes);
blockDataDestroy(pInfo->pCheckpointRes);
tSimpleHashCleanup(pInfo->pPkDeleted);

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

@ -60,14 +60,14 @@ void destroyStreamEventOperatorInfo(void* param) {
taosArrayDestroy(pInfo->pChildren);
}
colDataDestroy(&pInfo->twAggSup.timeWindowData);
pInfo->pDelRes = blockDataDestroy(pInfo->pDelRes);
blockDataDestroy(pInfo->pDelRes);
tSimpleHashCleanup(pInfo->pSeUpdated);
tSimpleHashCleanup(pInfo->pAllUpdated);
tSimpleHashCleanup(pInfo->pSeDeleted);
cleanupGroupResInfo(&pInfo->groupResInfo);
taosArrayDestroy(pInfo->historyWins);
pInfo->pDelRes = blockDataDestroy(pInfo->pCheckpointRes);
blockDataDestroy(pInfo->pCheckpointRes);
tSimpleHashCleanup(pInfo->pPkDeleted);

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

@ -123,8 +123,8 @@ void destroyStreamFillInfo(SStreamFillInfo* pFillInfo) {
static void destroyStreamFillOperatorInfo(void* param) {
SStreamFillOperatorInfo* pInfo = (SStreamFillOperatorInfo*)param;
pInfo->pFillInfo = destroyStreamFillInfo(pInfo->pFillInfo);
pInfo->pFillSup = destroyStreamFillSupporter(pInfo->pFillSup);
destroyStreamFillInfo(pInfo->pFillInfo);
destroyStreamFillSupporter(pInfo->pFillSup);
blockDataDestroy(pInfo->pRes);
pInfo->pRes = NULL;
blockDataDestroy(pInfo->pSrcBlock);

22
source/libs/executor/src/streamtimewindowoperator.c
View File

@ -465,11 +465,11 @@ void destroyStreamFinalIntervalOperatorInfo(void* param) {
taosHashCleanup(pInfo->pPullDataMap);
taosHashCleanup(pInfo->pFinalPullDataMap);
taosArrayDestroy(pInfo->pPullWins);
pInfo->pPullDataRes = blockDataDestroy(pInfo->pPullDataRes);
blockDataDestroy(pInfo->pPullDataRes);
taosArrayDestroy(pInfo->pDelWins);
pInfo->pDelRes = blockDataDestroy(pInfo->pDelRes);
pInfo->pMidRetriveRes = blockDataDestroy(pInfo->pMidRetriveRes);
pInfo->pMidPulloverRes = blockDataDestroy(pInfo->pMidPulloverRes);
blockDataDestroy(pInfo->pDelRes);
blockDataDestroy(pInfo->pMidRetriveRes);
blockDataDestroy(pInfo->pMidPulloverRes);
pInfo->stateStore.streamFileStateDestroy(pInfo->pState->pFileState);
taosArrayDestroy(pInfo->pMidPullDatas);
@ -486,7 +486,7 @@ void destroyStreamFinalIntervalOperatorInfo(void* param) {
pInfo->pUpdatedMap = NULL;
tSimpleHashCleanup(pInfo->pDeletedMap);
pInfo->pCheckpointRes = blockDataDestroy(pInfo->pCheckpointRes);
blockDataDestroy(pInfo->pCheckpointRes);
taosMemoryFreeClear(param);
}
@ -1943,7 +1943,7 @@ _error:
void destroyStreamAggSupporter(SStreamAggSupporter* pSup) {
tSimpleHashCleanup(pSup->pResultRows);
destroyDiskbasedBuf(pSup->pResultBuf);
pSup->pScanBlock = blockDataDestroy(pSup->pScanBlock);
blockDataDestroy(pSup->pScanBlock);
pSup->stateStore.streamFileStateDestroy(pSup->pState->pFileState);
taosMemoryFreeClear(pSup->pState);
taosMemoryFreeClear(pSup->pDummyCtx);
@ -1968,14 +1968,14 @@ void destroyStreamSessionAggOperatorInfo(void* param) {
}
colDataDestroy(&pInfo->twAggSup.timeWindowData);
pInfo->pDelRes = blockDataDestroy(pInfo->pDelRes);
pInfo->pWinBlock = blockDataDestroy(pInfo->pWinBlock);
blockDataDestroy(pInfo->pDelRes);
blockDataDestroy(pInfo->pWinBlock);
tSimpleHashCleanup(pInfo->pStUpdated);
tSimpleHashCleanup(pInfo->pStDeleted);
cleanupGroupResInfo(&pInfo->groupResInfo);
taosArrayDestroy(pInfo->historyWins);
pInfo->pCheckpointRes = blockDataDestroy(pInfo->pCheckpointRes);
blockDataDestroy(pInfo->pCheckpointRes);
tSimpleHashCleanup(pInfo->pPkDeleted);
taosMemoryFreeClear(param);
@ -3946,13 +3946,13 @@ void destroyStreamStateOperatorInfo(void* param) {
taosArrayDestroy(pInfo->pChildren);
}
colDataDestroy(&pInfo->twAggSup.timeWindowData);
pInfo->pDelRes = blockDataDestroy(pInfo->pDelRes);
blockDataDestroy(pInfo->pDelRes);
tSimpleHashCleanup(pInfo->pSeUpdated);
tSimpleHashCleanup(pInfo->pSeDeleted);
cleanupGroupResInfo(&pInfo->groupResInfo);
taosArrayDestroy(pInfo->historyWins);
pInfo->pCheckpointRes = blockDataDestroy(pInfo->pCheckpointRes);
blockDataDestroy(pInfo->pCheckpointRes);
tSimpleHashCleanup(pInfo->pPkDeleted);
taosMemoryFreeClear(param);