From 973946088f52315259091f89eea009b5ac823a7b Mon Sep 17 00:00:00 2001
From: Ganlin Zhao <ganlinzhao@hotmail.com>
Date: Fri, 11 Mar 2022 12:44:25 +0800
Subject: [PATCH] [TD-11216]<feature>: Time window related keywords add
 _qstart/_qstop/_qduration

---
 src/query/src/qAggMain.c | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/query/src/qAggMain.c b/src/query/src/qAggMain.c
index c282255977..c64ce371dc 100644
--- a/src/query/src/qAggMain.c
+++ b/src/query/src/qAggMain.c
@@ -5817,7 +5817,7 @@ static void window_start_function(SQLFunctionCtx *pCtx) {
 
 static void window_stop_function(SQLFunctionCtx *pCtx) {
   SET_VAL(pCtx, pCtx->size, 1);
-  if (pCtx->functionId == TSDB_FUNC_WSTART) {
+  if (pCtx->functionId == TSDB_FUNC_WSTOP) {
     *(int64_t *)(pCtx->pOutput) = pCtx->endTs;
   } else { //TSDB_FUNC_QSTOP
     *(TSKEY *)(pCtx->pOutput) = pCtx->qWindow.ekey;
@@ -5827,7 +5827,7 @@ static void window_stop_function(SQLFunctionCtx *pCtx) {
 static void window_duration_function(SQLFunctionCtx *pCtx) {
   SET_VAL(pCtx, pCtx->size, 1);
   int64_t duration;
-  if (pCtx->functionId == TSDB_FUNC_WSTART) {
+  if (pCtx->functionId == TSDB_FUNC_WDURATION) {
     duration = pCtx->endTs - pCtx->startTs;
   } else { //TSDB_FUNC_QDURATION
     duration = pCtx->qWindow.ekey - pCtx->qWindow.skey;
-- 
GitLab