xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix:add configure withTbName for tmq

This commit is contained in:
wangmm0220 2023-10-09 17:16:48 +08:00
parent 8e2bb951a8
commit 1275caf8fc
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/dnode/vnode/src/tq/tqUtil.c
View File

@ -53,11 +53,11 @@ void tqUpdateNodeStage(STQ* pTq, bool isLeader) {
} }
} }
static int32_t tqInitTaosxRsp(STaosxRsp* pRsp, STqOffsetVal pOffset) { static int32_t tqInitTaosxRsp(STaosxRsp* pRsp, STqOffsetVal pOffset, bool withTbName) {
pRsp->reqOffset = pOffset; pRsp->reqOffset = pOffset;
pRsp->rspOffset = pOffset; pRsp->rspOffset = pOffset;
pRsp->withTbName = 1; pRsp->withTbName = withTbName;
pRsp->withSchema = 1; pRsp->withSchema = 1;
pRsp->blockData = taosArrayInit(0, sizeof(void*)); pRsp->blockData = taosArrayInit(0, sizeof(void*));
pRsp->blockDataLen = taosArrayInit(0, sizeof(int32_t)); pRsp->blockDataLen = taosArrayInit(0, sizeof(int32_t));