This commit is contained in:
dapan1121 2021-02-25 16:36:46 +08:00
parent 16f30a5fac
commit 7763a2e6a3
1 changed files with 5 additions and 1 deletions

View File

@ -4743,7 +4743,11 @@ static FORCE_INLINE void setEnvForEachBlock(SQInfo* pQInfo, STableQueryInfo* pTa
}
if (QUERY_IS_INTERVAL_QUERY(pQuery)) {
setIntervalQueryRange(pQInfo, pBlockInfo->window.skey);
if (!QUERY_IS_ASC_QUERY(pRuntimeEnv->pQuery)) {
setIntervalQueryRange(pQInfo, pBlockInfo->window.ekey);
} else {
setIntervalQueryRange(pQInfo, pBlockInfo->window.skey);
}
} else { // non-interval query
setExecutionContext(pQInfo, pTableQueryInfo->groupIndex, pBlockInfo->window.ekey + step);
}