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

fix:[TD-33755]set tag=false error in tmq_get_json

This commit is contained in:
wangmm0220 2025-02-18 15:01:57 +08:00
parent 6b042d8b16
commit 425edfad72
2 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/client/src/clientRawBlockWrite.c
View File

@ -799,7 +799,7 @@ static void processAlterTable(SMqMetaRsp* metaRsp, cJSON** pJson) {
if (vAlterTbReq.tagType == TSDB_DATA_TYPE_VARBINARY) { if (vAlterTbReq.tagType == TSDB_DATA_TYPE_VARBINARY) {
bufSize = vAlterTbReq.nTagVal * 2 + 2 + 3; bufSize = vAlterTbReq.nTagVal * 2 + 2 + 3;
} else { } else {
bufSize = vAlterTbReq.nTagVal + 3; bufSize = vAlterTbReq.nTagVal + 32;
} }
buf = taosMemoryCalloc(bufSize, 1); buf = taosMemoryCalloc(bufSize, 1);
RAW_NULL_CHECK(buf); RAW_NULL_CHECK(buf);
@ -2315,8 +2315,6 @@ static void processSimpleMeta(SMqMetaRsp* pMetaRsp, cJSON** meta) {
processAlterTable(pMetaRsp, meta); processAlterTable(pMetaRsp, meta);
} else if (pMetaRsp->resMsgType == TDMT_VND_DROP_TABLE) { } else if (pMetaRsp->resMsgType == TDMT_VND_DROP_TABLE) {
processDropTable(pMetaRsp, meta); processDropTable(pMetaRsp, meta);
} else if (pMetaRsp->resMsgType == TDMT_VND_DROP_TABLE) {
processDropTable(pMetaRsp, meta);
} else if (pMetaRsp->resMsgType == TDMT_VND_DELETE) { } else if (pMetaRsp->resMsgType == TDMT_VND_DELETE) {
processDeleteTable(pMetaRsp, meta); processDeleteTable(pMetaRsp, meta);
} }

7
utils/test/c/tmq_write_raw_test.c
View File

@ -136,6 +136,13 @@ int buildDatabase(TAOS* pConn, TAOS_RES* pRes) {
} }
taos_free_result(pRes); taos_free_result(pRes);
pRes = taos_query(pConn, "alter table ct0 set tag t4=false");
if (taos_errno(pRes) != 0) {
printf("alter table ct0 set tag t4=false, reason:%s\n", taos_errstr(pRes));
return -1;
}
taos_free_result(pRes);
return 0; return 0;
} }