fix(query): set the gid for stream result.

285bf707 · Haojun Liao · b2282e91 · 285bf707
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/libs/executor/src/timewindowoperator.c source/libs/executor/src/timewindowoperator.c +1 -1

未找到文件。
--- a/source/libs/executor/src/timewindowoperator.c
+++ b/source/libs/executor/src/timewindowoperator.c
@@ -1128,7 +1128,7 @@ static SSDataBlock* doStreamIntervalAgg(SOperatorInfo* pOperator) {
      continue;
    }

-    pUpdated = hashIntervalAgg(pOperator, &pInfo->binfo.resultRowInfo, pBlock, 0);
+    pUpdated = hashIntervalAgg(pOperator, &pInfo->binfo.resultRowInfo, pBlock, pBlock->info.groupId);
  }

  finalizeUpdatedResult(pOperator->numOfExprs, pInfo->aggSup.pResultBuf, pUpdated, pInfo->binfo.rowCellInfoOffset);