fix(query): set group id in stream scanner.

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

Showing with 2 addition and 0 deletion

source/libs/executor/src/scanoperator.c source/libs/executor/src/scanoperator.c +2 -0

未找到文件。
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -882,6 +882,8 @@ static SSDataBlock* doStreamBlockScan(SOperatorInfo* pOperator) {
      // TODO temporarily used, when the statement of "partition by tbname" is ready, remove this
      if (pInfo->assignBlockUid) {
        pInfo->pRes->info.groupId = uid;
+      } else {
+        pInfo->pRes->info.groupId = groupId;
      }

      int32_t numOfCols = pInfo->pRes->info.numOfCols;