diff --git a/source/dnode/vnode/src/tq/tqRead.c b/source/dnode/vnode/src/tq/tqRead.c index 3aaf5cd60d2f673f67ad326c0bea9957ef787062..082e31ea9138659df7b396d6770ec882f30ce4f6 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);