From 50ba55561b3bcb879c5a3bf9b01b2ac60defd839 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Fri, 5 May 2023 22:11:59 +0800
Subject: [PATCH] fix(stream): set correct group id and table id.

---
 source/dnode/vnode/src/tq/tqRead.c | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/source/dnode/vnode/src/tq/tqRead.c b/source/dnode/vnode/src/tq/tqRead.c
index 3aaf5cd60d..082e31ea91 100644
--- a/source/dnode/vnode/src/tq/tqRead.c
+++ b/source/dnode/vnode/src/tq/tqRead.c
@@ -565,6 +565,10 @@ int32_t tqRetrieveDataBlock(SSDataBlock* pBlock, STqReader* pReader, SSubmitTbDa
     if (blockDataGetNumOfCols(pBlock) > 0) {
       blockDataDestroy(pReader->pResBlock);
       pReader->pResBlock = createDataBlock();
+      pBlock = pReader->pResBlock;
+
+      pBlock->info.id.uid = uid;
+      pBlock->info.version = pReader->msg.ver;
     }
 
     int32_t numOfCols = taosArrayGetSize(pReader->pColIdList);