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

fix:[TS-5528] insert error in sml

This commit is contained in:
wangmm0220 2024-10-15 15:25:28 +08:00
parent 4904667471
commit c9f835e60d
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/client/src/clientSml.c
View File

@ -262,7 +262,7 @@ int32_t smlBuildSuperTableInfo(SSmlHandle *info, SSmlLineInfo *currElement, SSml
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;
} }
void isSmlColAligned(SSmlHandle *info, int cnt, SSmlKv *kv) { bool isSmlColAligned(SSmlHandle *info, int cnt, SSmlKv *kv) {
// cnt begin 0, add ts so + 2 // cnt begin 0, add ts so + 2
if (unlikely(cnt + 2 > info->currSTableMeta->tableInfo.numOfColumns)) { if (unlikely(cnt + 2 > info->currSTableMeta->tableInfo.numOfColumns)) {
goto END; goto END;
@ -288,11 +288,12 @@ void isSmlColAligned(SSmlHandle *info, int cnt, SSmlKv *kv) {
maxKV->length = kv->length; maxKV->length = kv->length;
info->needModifySchema = true; info->needModifySchema = true;
} }
return; return true;
END: END:
info->dataFormat = false; info->dataFormat = false;
info->reRun = true; info->reRun = true;
return false;
} }
bool isSmlTagAligned(SSmlHandle *info, int cnt, SSmlKv *kv) { bool isSmlTagAligned(SSmlHandle *info, int cnt, SSmlKv *kv) {