diff --git a/src/tsdb/src/tsdbFile.c b/src/tsdb/src/tsdbFile.c index 63b219ebcb..b22d5fa834 100644 --- a/src/tsdb/src/tsdbFile.c +++ b/src/tsdb/src/tsdbFile.c @@ -300,8 +300,8 @@ int tsdbUpdateFileHeader(SFile *pFile, uint32_t version) { char buf[TSDB_FILE_HEAD_SIZE] = "\0"; void *pBuf = (void *)buf; - taosEncodeFixedU32(pBuf, version); - tsdbEncodeSFileInfo(pBuf, &(pFile->info)); + taosEncodeFixedU32((void *)(&pBuf), version); + tsdbEncodeSFileInfo((void *)(&pBuf), &(pFile->info)); taosCalcChecksumAppend(0, (uint8_t *)buf, TSDB_FILE_HEAD_SIZE); diff --git a/src/tsdb/src/tsdbMemTable.c b/src/tsdb/src/tsdbMemTable.c index 72a1b307de..f2e3407b66 100644 --- a/src/tsdb/src/tsdbMemTable.c +++ b/src/tsdb/src/tsdbMemTable.c @@ -161,7 +161,7 @@ int tsdbTakeMemSnapshot(STsdbRepo *pRepo, SMemTable **pMem, SMemTable **pIMem) { if (tsdbLockRepo(pRepo) < 0) return -1; *pMem = pRepo->mem; - *pIMem = pRepo->mem; + *pIMem = pRepo->imem; tsdbRefMemTable(pRepo, *pMem); tsdbRefMemTable(pRepo, *pIMem); diff --git a/src/util/src/tkvstore.c b/src/util/src/tkvstore.c index 1c7d93b307..1ffc86bf5e 100644 --- a/src/util/src/tkvstore.c +++ b/src/util/src/tkvstore.c @@ -241,9 +241,9 @@ int tdUpdateKVStoreRecord(SKVStore *pStore, uint64_t uid, void *cont, int contLe pStore->info.size += (sizeof(SKVRecord) + contLen); SKVRecord *pRecord = taosHashGet(pStore->map, (void *)&uid, sizeof(uid)); if (pRecord != NULL) { // just to insert - pStore->info.nRecords++; - } else { pStore->info.tombSize += pRecord->size; + } else { + pStore->info.nRecords++; } taosHashPut(pStore->map, (void *)(&uid), sizeof(uid), (void *)(&rInfo), sizeof(rInfo));