fix bug

7e600907 · dapan1121 · 08132adc · 7e600907
显示空白变更内容
内联并排

Showing with 4 addition and 0 deletion

src/query/src/qAggMain.c src/query/src/qAggMain.c +4 -0

未找到文件。
--- a/src/query/src/qAggMain.c
+++ b/src/query/src/qAggMain.c
@@ -2616,6 +2616,10 @@ static void top_function_f(SQLFunctionCtx *pCtx, int32_t index) {
  STopBotInfo *pRes = getTopBotOutputInfo(pCtx);
  assert(pRes->num >= 0);
+  if ((void *)pRes->res[0] != (void *)((char *)pRes + sizeof(STopBotInfo) + POINTER_BYTES * pCtx->param[0].i64)) {
+    buildTopBotStruct(pRes, pCtx);
+  }
  SET_VAL(pCtx, 1, 1);
  TSKEY ts = GET_TS_DATA(pCtx, index);