Merge pull request #23833 from taosdata/fix/TD-27532
stream event reload state
This commit is contained in:
commit
4439c1e4f5
|
@ -603,7 +603,7 @@ void streamEventReloadState(SOperatorInfo* pOperator) {
|
||||||
pSeKeyBuf[i].groupId, i);
|
pSeKeyBuf[i].groupId, i);
|
||||||
getSessionWindowInfoByKey(pAggSup, pSeKeyBuf + i, &curInfo.winInfo);
|
getSessionWindowInfoByKey(pAggSup, pSeKeyBuf + i, &curInfo.winInfo);
|
||||||
setEventWindowFlag(pAggSup, &curInfo);
|
setEventWindowFlag(pAggSup, &curInfo);
|
||||||
if (!curInfo.pWinFlag->startFlag || curInfo.pWinFlag->endFlag) {
|
if (!curInfo.pWinFlag->startFlag || !curInfo.pWinFlag->endFlag) {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue