fix(query): fix interp + fill(linear) datapoint outside interpolation window

will be included

TD-18392
This commit is contained in:
Ganlin Zhao 2022-08-19 12:28:27 +08:00
parent 240747abed
commit f20887ee97
1 changed files with 4 additions and 4 deletions

View File

@ -2413,12 +2413,12 @@ static SSDataBlock* doTimeslice(SOperatorInfo* pOperator) {
break; break;
} }
} }
}
if (pSliceInfo->current > pSliceInfo->win.ekey) { if (pSliceInfo->current > pSliceInfo->win.ekey) {
doSetOperatorCompleted(pOperator); doSetOperatorCompleted(pOperator);
break; break;
} }
}
if (ts == pSliceInfo->current) { if (ts == pSliceInfo->current) {
for (int32_t j = 0; j < pOperator->exprSupp.numOfExprs; ++j) { for (int32_t j = 0; j < pOperator->exprSupp.numOfExprs; ++j) {