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

fix:[TD-20612] error if write raw with some cols

This commit is contained in:
wangmm0220 2022-11-29 10:49:47 +08:00
parent 5bed172337
commit 829a7631b3
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/client/src/clientRawBlockWrite.c
View File

@ -1794,12 +1794,12 @@ static int32_t tmqWriteRawDataImpl(TAOS* taos, void* data, int32_t dataLen) {
} }
char* colData = rspObj.resInfo.row[i]; char* colData = rspObj.resInfo.row[i];
if (!colData) { if (!colData) {
tdAppendColValToRow(&rb, pColumn->colId, pColumn->type, TD_VTYPE_NULL, NULL, false, offset, k); tdAppendColValToRow(&rb, pColumn->colId, pColumn->type, TD_VTYPE_NULL, NULL, false, offset, i);
} else { } else {
if (IS_VAR_DATA_TYPE(pColumn->type)) { if (IS_VAR_DATA_TYPE(pColumn->type)) {
colData -= VARSTR_HEADER_SIZE; colData -= VARSTR_HEADER_SIZE;
} }
tdAppendColValToRow(&rb, pColumn->colId, pColumn->type, TD_VTYPE_NORM, colData, true, offset, k); tdAppendColValToRow(&rb, pColumn->colId, pColumn->type, TD_VTYPE_NORM, colData, true, offset, i);
} }
if (pColumn->colId != PRIMARYKEY_TIMESTAMP_COL_ID) { if (pColumn->colId != PRIMARYKEY_TIMESTAMP_COL_ID) {