diff --git a/internal/datacoord/compaction.go b/internal/datacoord/compaction.go index d4202863d8..246b3e88a8 100644 --- a/internal/datacoord/compaction.go +++ b/internal/datacoord/compaction.go @@ -254,9 +254,9 @@ func (c *compactionPlanHandler) expireCompaction(ts Timestamp) error { } func (c *compactionPlanHandler) isTimeout(now Timestamp, start Timestamp, timeout int32) bool { - starttime, _ := tsoutil.ParseTS(start) + startTime, _ := tsoutil.ParseTS(start) ts, _ := tsoutil.ParseTS(now) - return int32(ts.Sub(starttime).Seconds()) >= timeout + return int32(ts.Sub(startTime).Seconds()) >= timeout } // isFull return true if the task pool is full