提交 595fdbed 编写于 作者: S slzhou

fix: compact range - convert range only

上级 3843e296
...@@ -1345,8 +1345,12 @@ static int32_t mnodeCompact(SDbObj *pDb, SCompactMsg *pCompactMsg) { ...@@ -1345,8 +1345,12 @@ static int32_t mnodeCompact(SDbObj *pDb, SCompactMsg *pCompactMsg) {
pIter = mnodeGetNextVgroup(pIter, &pVgroup); pIter = mnodeGetNextVgroup(pIter, &pVgroup);
if (pVgroup == NULL) break; if (pVgroup == NULL) break;
if (pVgroup->pDb == pDb && pVgroup->vgId == buf[i]) { if (pVgroup->pDb == pDb && pVgroup->vgId == buf[i]) {
skey = convertTimePrecision(skey, TSDB_TIME_PRECISION_NANO, pVgroup->pDb->cfg.precision); if (skey != INT64_MIN) {
ekey = convertTimePrecision(ekey, TSDB_TIME_PRECISION_NANO, pVgroup->pDb->cfg.precision); skey = convertTimePrecision(skey, TSDB_TIME_PRECISION_NANO, pVgroup->pDb->cfg.precision);
}
if (ekey != INT64_MAX) {
ekey = convertTimePrecision(ekey, TSDB_TIME_PRECISION_NANO, pVgroup->pDb->cfg.precision);
}
mInfo("vgId: %d send compact msg. start %"PRId64 " end %"PRId64, pVgroup->vgId, skey, ekey); mInfo("vgId: %d send compact msg. start %"PRId64 " end %"PRId64, pVgroup->vgId, skey, ekey);
mnodeSendCompactVgroupMsg(pVgroup, skey, ekey); mnodeSendCompactVgroupMsg(pVgroup, skey, ekey);
mnodeDecVgroupRef(pVgroup); mnodeDecVgroupRef(pVgroup);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册