From 9aa5ee6ccfe37fe0b9bba7b86b2a6c0d5df31385 Mon Sep 17 00:00:00 2001 From: Minglei Jin Date: Mon, 4 Jul 2022 16:58:42 +0800 Subject: [PATCH] tsdbCache: fix row duplication --- source/dnode/vnode/src/tsdb/tsdbCache.c | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/tsdb/tsdbCache.c b/source/dnode/vnode/src/tsdb/tsdbCache.c index 921702d866..c9554b5688 100644 --- a/source/dnode/vnode/src/tsdb/tsdbCache.c +++ b/source/dnode/vnode/src/tsdb/tsdbCache.c @@ -139,7 +139,11 @@ int32_t tsdbCacheInsertLastrow(SLRUCache *pCache, STsdb *pTsdb, tb_uid_t uid, ST } else { taosLRUCacheRelease(pCache, h, true); // tsdbCacheDeleteLastrow(pCache, uid, TSKEY_MAX); - + if (dup) { + cacheRow = tdRowDup(row); + } else { + cacheRow = row; + } _taos_lru_deleter_t deleter = deleteTableCacheLastrow; LRUStatus status = taosLRUCacheInsert(pCache, key, keyLen, cacheRow, TD_ROW_LEN(cacheRow), deleter, NULL, TAOS_LRU_PRIORITY_LOW);