Skip to content

Commit

Permalink
Merge pull request #29221 from taosdata/fix/TD-33282
Browse files Browse the repository at this point in the history
fix(tsdb/cache del): remove commit w.r.t del
  • Loading branch information
guanshengliang authored Dec 20, 2024
2 parents 1ce6f4a + e389583 commit da46ea3
Showing 1 changed file with 4 additions and 12 deletions.
16 changes: 4 additions & 12 deletions source/dnode/vnode/src/tsdb/tsdbCache.c
Original file line number Diff line number Diff line change
Expand Up @@ -2635,23 +2635,15 @@ int32_t tsdbCacheGetBatch(STsdb *pTsdb, tb_uid_t uid, SArray *pLastArray, SCache
}

int32_t tsdbCacheDel(STsdb *pTsdb, tb_uid_t suid, tb_uid_t uid, TSKEY sKey, TSKEY eKey) {
int32_t code = 0, lino = 0;
// fetch schema
int32_t code = 0, lino = 0;
STSchema *pTSchema = NULL;
int sver = -1;
int numKeys = 0;
SArray *remainCols = NULL;

TAOS_CHECK_RETURN(metaGetTbTSchemaEx(pTsdb->pVnode->pMeta, suid, uid, sver, &pTSchema));

// build keys & multi get from rocks
int numCols = pTSchema->numOfCols;
int numKeys = 0;
SArray *remainCols = NULL;

code = tsdbCacheCommit(pTsdb);
if (code != TSDB_CODE_SUCCESS) {
tsdbTrace("vgId:%d, %s commit failed at line %d since %s", TD_VID(pTsdb->pVnode), __func__, __LINE__,
tstrerror(code));
}
int numCols = pTSchema->numOfCols;

(void)taosThreadMutexLock(&pTsdb->lruMutex);

Expand Down

0 comments on commit da46ea3

Please sign in to comment.