cos/multi-writing: fix remove with different version
This commit is contained in:
parent
16b65b7311
commit
e14d4e172d
|
@ -386,7 +386,11 @@ int32_t tsdbTFileSetApplyEdit(STsdb *pTsdb, const STFileSet *fset1, STFileSet *f
|
||||||
fobj2->f[0] = fobj1->f[0];
|
fobj2->f[0] = fobj1->f[0];
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
tsdbTFileObjRemoveUpdateLC(fobj2);
|
if (fobj1->f->cid != fobj2->f->cid) {
|
||||||
|
tsdbTFileObjRemove(fobj2);
|
||||||
|
} else {
|
||||||
|
tsdbTFileObjRemoveUpdateLC(fobj2);
|
||||||
|
}
|
||||||
code = tsdbTFileObjInit(pTsdb, fobj1->f, &fset2->farr[ftype]);
|
code = tsdbTFileObjInit(pTsdb, fobj1->f, &fset2->farr[ftype]);
|
||||||
if (code) return code;
|
if (code) return code;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue