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

fix(query): set the pk for interp query.

This commit is contained in:
Haojun Liao 2024-05-11 11:11:09 +08:00
parent 8059ce72d2
commit c54751e7e2
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/libs/executor/src/timesliceoperator.c
View File

@ -204,6 +204,11 @@ static bool checkDuplicateTimestamps(STimeSliceOperatorInfo* pSliceInfo, SColumn
SRowKey cur = {.ts = currentTs, .numOfPKs = (pPkCol != NULL)? 1:0}; SRowKey cur = {.ts = currentTs, .numOfPKs = (pPkCol != NULL)? 1:0};
if (pPkCol != NULL) { if (pPkCol != NULL) {
cur.pks[0].type = pPkCol->info.type; cur.pks[0].type = pPkCol->info.type;
if (IS_VAR_DATA_TYPE(pPkCol->info.type)) {
cur.pks[0].pData = (uint8_t*)colDataGetVarData(pPkCol, rows);
} else {
memcpy(&cur.pks[0].val, colDataGetData(pPkCol, rows), pPkCol->info.bytes);
}
} }
// let's discard the duplicated ts // let's discard the duplicated ts