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

add log

This commit is contained in:
54liuyao 2024-09-03 09:49:37 +08:00
parent d4062efa1c
commit 54f81fa1f8
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/streamtimesliceoperator.c
View File

@ -91,6 +91,7 @@ void streamTimeSliceReloadState(SOperatorInfo* pOperator) {
TSKEY ts = *(TSKEY*)((char*)pBuf + size - sizeof(TSKEY));
pInfo->twAggSup.maxTs = TMAX(pInfo->twAggSup.maxTs, ts);
pAggSup->stateStore.streamStateReloadInfo(pAggSup->pState, ts);
qDebug("===stream=== reload state. reload ts:%" PRId64, ts);
if (!pInfo->pUpdatedMap && num > 0) {
_hash_fn_t hashFn = taosGetDefaultHashFunction(TSDB_DATA_TYPE_BINARY);