From a4676fc74b78aec7b18faa34bb2e85e67ce1ac21 Mon Sep 17 00:00:00 2001 From: liuyao <54liuyao@163.com> Date: Tue, 18 Jul 2023 10:43:35 +0800 Subject: [PATCH] init winkey --- source/libs/executor/src/timewindowoperator.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/libs/executor/src/timewindowoperator.c b/source/libs/executor/src/timewindowoperator.c index b436362e1c..04f73707c2 100644 --- a/source/libs/executor/src/timewindowoperator.c +++ b/source/libs/executor/src/timewindowoperator.c @@ -2648,6 +2648,7 @@ void doStreamIntervalDecodeOpState(void* buf, int32_t len, SOperatorInfo* pOpera for (int32_t i = 0; i < mapSize; i++) { SWinKey key = {0}; SRowBuffPos* pPos = taosMemoryCalloc(1, sizeof(SRowBuffPos)); + pPos->pKey = taosMemoryCalloc(1, sizeof(SWinKey)); buf = decodeSWinKey(buf, &key); buf = decodeSRowBuffPos(buf, pPos); tSimpleHashPut(pInfo->aggSup.pResultRowHashTable, &key, sizeof(SWinKey), &pPos, POINTER_BYTES);