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

fix:clear hashmap if rerun schemaless

This commit is contained in:
wangmm0220 2023-02-07 00:17:25 +08:00
parent 4f949213da
commit bec6cdf784
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1120,7 +1120,7 @@ SSmlHandle *smlBuildSmlInfo(TAOS *taos) {
info->maxTagKVs = taosArrayInit(8, sizeof(SSmlKv)); info->maxTagKVs = taosArrayInit(8, sizeof(SSmlKv));
info->preLineColKV = taosArrayInit(8, sizeof(SSmlKv)); info->preLineColKV = taosArrayInit(8, sizeof(SSmlKv));
if (NULL == info->pVgHash) { if (NULL == info->pVgHash || NULL == info->childTables || NULL == info->superTables) {
uError("create SSmlHandle failed"); uError("create SSmlHandle failed");
goto cleanup; goto cleanup;
} }
@ -1299,6 +1299,9 @@ int32_t smlClearForRerun(SSmlHandle *info) {
oneSTable = (SSmlSTableMeta **)taosHashIterate(info->superTables, oneSTable); oneSTable = (SSmlSTableMeta **)taosHashIterate(info->superTables, oneSTable);
} }
taosHashClear(info->childTables);
taosHashClear(info->superTables);
if (!info->dataFormat) { if (!info->dataFormat) {
if (unlikely(info->lines != NULL)) { if (unlikely(info->lines != NULL)) {
uError("SML:0x%" PRIx64 " info->lines != NULL", info->id); uError("SML:0x%" PRIx64 " info->lines != NULL", info->id);