From 595fdbedcac06a9fdd98f16a543c263827c9753e Mon Sep 17 00:00:00 2001 From: slzhou Date: Wed, 23 Aug 2023 09:46:55 +0800 Subject: [PATCH] fix: compact range - convert range only --- src/mnode/src/mnodeDb.c | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/src/mnode/src/mnodeDb.c b/src/mnode/src/mnodeDb.c index 3573ee0c98..749dc31c39 100644 --- a/src/mnode/src/mnodeDb.c +++ b/src/mnode/src/mnodeDb.c @@ -1345,8 +1345,12 @@ static int32_t mnodeCompact(SDbObj *pDb, SCompactMsg *pCompactMsg) { pIter = mnodeGetNextVgroup(pIter, &pVgroup); if (pVgroup == NULL) break; if (pVgroup->pDb == pDb && pVgroup->vgId == buf[i]) { - skey = convertTimePrecision(skey, TSDB_TIME_PRECISION_NANO, pVgroup->pDb->cfg.precision); - ekey = convertTimePrecision(ekey, TSDB_TIME_PRECISION_NANO, pVgroup->pDb->cfg.precision); + if (skey != INT64_MIN) { + 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); mnodeSendCompactVgroupMsg(pVgroup, skey, ekey); mnodeDecVgroupRef(pVgroup); -- GitLab