diff --git a/source/common/src/tmisce.c b/source/common/src/tmisce.c index 0a9e8f434b..d2b52b201e 100644 --- a/source/common/src/tmisce.c +++ b/source/common/src/tmisce.c @@ -228,6 +228,8 @@ int32_t dumpConfToDataBlock(SSDataBlock* pBlock, int32_t startCol) { blockDataEnsureCapacity(pBlock, cfgGetSize(pConf)); SConfigIter* pIter = cfgCreateIter(pConf); + cfgLock(pConf); + while ((pItem = cfgNextIter(pIter)) != NULL) { col = startCol; @@ -253,6 +255,8 @@ int32_t dumpConfToDataBlock(SSDataBlock* pBlock, int32_t startCol) { numOfRows++; } + cfgUnLock(pConf); + pBlock->info.rows = numOfRows; cfgDestroyIter(pIter);