diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c
index e6ae61e70ad1b923786c7b1f31c88237d4d5fabb..47a5e1522f7438e632c40f34e854f5b38493d7ae 100644
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -1410,6 +1410,8 @@ static void rowwiseApplyFunctions(SQueryRuntimeEnv *pRuntimeEnv, SDataStatis *pS
     item->lastKey = (QUERY_IS_ASC_QUERY(pQuery)? pDataBlockInfo->window.ekey:pDataBlockInfo->window.skey) + step;
   }
 
+  item->cur = tsBufGetCursor(pRuntimeEnv->pTSBuf);
+
   // todo refactor: extract method
   for(int32_t i = 0; i < pQuery->numOfOutput; ++i) {
     if (pQuery->pSelectExpr[i].base.functionId != TSDB_FUNC_ARITHM) {