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

fix(query): fix error in filter.

This commit is contained in:
Haojun Liao 2023-01-04 00:19:04 +08:00
parent 00c2d382b1
commit 1a97a659bc
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/executor/src/executorimpl.c
View File

@ -930,7 +930,7 @@ void extractQualifiedTupleByFilterResult(SSDataBlock* pBlock, const SColumnInfoD
if (colDataIsNull_f(pBitmap, j)) { if (colDataIsNull_f(pBitmap, j)) {
colDataSetNull_f(pDst->nullbitmap, numOfRows); colDataSetNull_f(pDst->nullbitmap, numOfRows);
} else { } else {
((int32_t*)pDst->pData)[numOfRows++] = ((int32_t*)pDst->pData)[j]; ((int32_t*)pDst->pData)[numOfRows] = ((int32_t*)pDst->pData)[j];
} }
numOfRows += 1; numOfRows += 1;
j += 1; j += 1;
@ -946,7 +946,7 @@ void extractQualifiedTupleByFilterResult(SSDataBlock* pBlock, const SColumnInfoD
if (colDataIsNull_f(pBitmap, j)) { if (colDataIsNull_f(pBitmap, j)) {
colDataSetNull_f(pDst->nullbitmap, numOfRows); colDataSetNull_f(pDst->nullbitmap, numOfRows);
} else { } else {
((int16_t*)pDst->pData)[numOfRows++] = ((int16_t*)pDst->pData)[j]; ((int16_t*)pDst->pData)[numOfRows] = ((int16_t*)pDst->pData)[j];
} }
numOfRows += 1; numOfRows += 1;
j += 1; j += 1;