From b6d11287507343105b8ad180942d7aad6c8eaaed Mon Sep 17 00:00:00 2001 From: Liu Jicong Date: Sat, 4 Sep 2021 22:29:17 +0800 Subject: [PATCH] fix insert dump (#7779) fix insert dump --- src/tsdb/src/tsdbMemTable.c | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/src/tsdb/src/tsdbMemTable.c b/src/tsdb/src/tsdbMemTable.c index e766d97a97..6b0a707e76 100644 --- a/src/tsdb/src/tsdbMemTable.c +++ b/src/tsdb/src/tsdbMemTable.c @@ -779,7 +779,7 @@ static int tsdbInsertDataToTable(STsdbRepo* pRepo, SSubmitBlk* pBlock, int32_t * int32_t points = 0; STable *pTable = NULL; SSubmitBlkIter blkIter = {0}; - SMemTable *pMemTable = NULL; + SMemTable *pMemTable = pRepo->mem; STableData *pTableData = NULL; STsdbCfg *pCfg = &(pRepo->config); @@ -787,17 +787,18 @@ static int tsdbInsertDataToTable(STsdbRepo* pRepo, SSubmitBlk* pBlock, int32_t * if(blkIter.row == NULL) return 0; TSKEY firstRowKey = memRowKey(blkIter.row); - tsdbAllocBytes(pRepo, 0); - pMemTable = pRepo->mem; + if (pMemTable == NULL) { + pMemTable = tsdbNewMemTable(pRepo); + if (pMemTable == NULL) return -1; + pRepo->mem = pMemTable; + } - ASSERT(pMemTable != NULL); ASSERT(pBlock->tid < pMeta->maxTables); pTable = pMeta->tables[pBlock->tid]; ASSERT(pTable != NULL && TABLE_UID(pTable) == pBlock->uid); - if (TABLE_TID(pTable) >= pMemTable->maxTables) { if (tsdbAdjustMemMaxTables(pMemTable, pMeta->maxTables) < 0) { return -1; -- GitLab