xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix skyline init

This commit is contained in:
Minglei Jin 2024-12-06 15:09:45 +08:00
parent ec0d8409a3
commit 20e4e7cd71
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
source/dnode/vnode/src/tsdb/tsdbCache.c
View File

@ -606,7 +606,6 @@ int32_t tsdbLoadFromImem(SMemTable *imem, int64_t suid, int64_t uid) {
int32_t lino = 0; int32_t lino = 0;
STsdb *pTsdb = imem->pTsdb; STsdb *pTsdb = imem->pTsdb;
SArray *pMemDelData = NULL; SArray *pMemDelData = NULL;
SArray *pTombData = NULL;
SArray *pSkyline = NULL; SArray *pSkyline = NULL;
int64_t iSkyline = 0; int64_t iSkyline = 0;
STbDataIter tbIter = {0}; STbDataIter tbIter = {0};
@ -626,7 +625,12 @@ int32_t tsdbLoadFromImem(SMemTable *imem, int64_t suid, int64_t uid) {
// tsdbBuildDeleteSkyline // tsdbBuildDeleteSkyline
size_t delSize = TARRAY_SIZE(pMemDelData); size_t delSize = TARRAY_SIZE(pMemDelData);
if (delSize > 0) { if (delSize > 0) {
TAOS_CHECK_EXIT(tsdbBuildDeleteSkyline(pTombData, 0, (int32_t)(delSize - 1), pSkyline)); pSkyline = taosArrayInit(32, sizeof(TSDBKEY));
if (!pSkyline) {
TAOS_CHECK_EXIT(terrno);
}
TAOS_CHECK_EXIT(tsdbBuildDeleteSkyline(pMemDelData, 0, (int32_t)(delSize - 1), pSkyline));
iSkyline = taosArrayGetSize(pSkyline) - 1; iSkyline = taosArrayGetSize(pSkyline) - 1;
} }