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);
     }
   }