From 54f81fa1f891886e4accd8b8356a77feedb7c8fc Mon Sep 17 00:00:00 2001 From: 54liuyao <54liuyao> Date: Tue, 3 Sep 2024 09:49:37 +0800 Subject: [PATCH] add log --- source/libs/executor/src/streamtimesliceoperator.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/libs/executor/src/streamtimesliceoperator.c b/source/libs/executor/src/streamtimesliceoperator.c index eed49032a6..617ee7c526 100644 --- a/source/libs/executor/src/streamtimesliceoperator.c +++ b/source/libs/executor/src/streamtimesliceoperator.c @@ -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);