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

Merge pull request #22137 from taosdata/fix/ly_test 

transform stream state
This commit is contained in:
Haojun Liao 2023-07-21 13:42:44 +08:00 committed by GitHub
parent 2ef01728ca 4451b2185a
commit b5ff9182da
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/libs/executor/src/timewindowoperator.c
View File

@ -2753,6 +2753,7 @@ void streamIntervalReloadState(SOperatorInfo* pOperator) {
strlen(STREAM_INTERVAL_OP_STATE_NAME), &pBuf, &size);
TSKEY ts = *(TSKEY*)pBuf;
taosMemoryFree(pBuf);
pInfo->twAggSup.maxTs = TMAX(pInfo->twAggSup.maxTs, ts);
pInfo->statestore.streamStateReloadInfo(pInfo->pState, ts);
}
SOperatorInfo* downstream = pOperator->pDownstream[0];