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

fix(query): fix interp fill(next) result errors

This commit is contained in:
Ganlin Zhao 2022-08-06 16:18:11 +08:00
parent 784752010a
commit 8c3cc0161a
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/libs/executor/src/timewindowoperator.c
View File

@ -2344,8 +2344,9 @@ static SSDataBlock* doTimeslice(SOperatorInfo* pOperator) {
break; break;
} }
} else if (ts < pSliceInfo->current) { } else if (ts < pSliceInfo->current) {
//in case interpolation window starts and ends between two datapoints, fill(prev) need to interpolate //in case interpolation window starts and ends between two datapoints, fill(prev), fill(next) need to interpolate
doKeepPrevRows(pSliceInfo, pBlock, i); doKeepPrevRows(pSliceInfo, pBlock, i);
doKeepNextRows(pSliceInfo, pBlock, i + 1);
if (i < pBlock->info.rows - 1) { if (i < pBlock->info.rows - 1) {
int64_t nextTs = *(int64_t*)colDataGetData(pTsCol, i + 1); int64_t nextTs = *(int64_t*)colDataGetData(pTsCol, i + 1);