From d32a80a87276f7895f421f2a18c54b2aa19ad4ce Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sat, 11 May 2024 17:05:56 +0800 Subject: [PATCH] fix(query): set correct row index. --- source/libs/executor/src/timesliceoperator.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/source/libs/executor/src/timesliceoperator.c b/source/libs/executor/src/timesliceoperator.c index 8440f51cb0..9a84127be6 100644 --- a/source/libs/executor/src/timesliceoperator.c +++ b/source/libs/executor/src/timesliceoperator.c @@ -205,9 +205,9 @@ static bool checkDuplicateTimestamps(STimeSliceOperatorInfo* pSliceInfo, SColumn if (pPkCol != NULL) { cur.pks[0].type = pPkCol->info.type; if (IS_VAR_DATA_TYPE(pPkCol->info.type)) { - cur.pks[0].pData = (uint8_t*)colDataGetVarData(pPkCol, rows); + cur.pks[0].pData = (uint8_t*)colDataGetVarData(pPkCol, curIndex); } else { - memcpy(&cur.pks[0].val, colDataGetData(pPkCol, rows), pPkCol->info.bytes); + memcpy(&cur.pks[0].val, colDataGetData(pPkCol, curIndex), pPkCol->info.bytes); } }