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

fix:<TD-17539> error if stable alreadys & modify tmq struct

This commit is contained in:
wangmm0220 2022-07-19 17:20:15 +08:00
parent 958cdf8e39
commit 3033afd6e8
3 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
include/client/taos.h
View File

@ -259,7 +259,7 @@ enum tmq_res_t {
TMQ_RES_TABLE_META = 2, TMQ_RES_TABLE_META = 2,
}; };
typedef struct { typedef struct tmq_raw_data{
void* raw_meta; void* raw_meta;
uint32_t raw_meta_len; uint32_t raw_meta_len;
uint16_t raw_meta_type; uint16_t raw_meta_type;

10
source/client/test/smlTest.cpp
View File

File diff suppressed because one or more lines are too long

2
source/libs/parser/src/parInsert.c
View File

@ -2385,7 +2385,7 @@ int32_t smlBindData(void* handle, SArray* tags, SArray* colsSchema, SArray* cols
if (format) { if (format) {
if (j < rowDataSize) { if (j < rowDataSize) {
kv = taosArrayGetP(rowData, j); kv = taosArrayGetP(rowData, j);
if (rowDataSize != spd->numOfBound && if (rowDataSize != spd->numOfBound && j != 0 &&
(kv->keyLen != strlen(pColSchema->name) || strncmp(kv->key, pColSchema->name, kv->keyLen) != 0)) { (kv->keyLen != strlen(pColSchema->name) || strncmp(kv->key, pColSchema->name, kv->keyLen) != 0)) {
kv = NULL; kv = NULL;
} else { } else {