From e36f7287ae5479bd540f338e38446a171047845a Mon Sep 17 00:00:00 2001 From: godchen Date: Fri, 17 Dec 2021 19:14:59 +0800 Subject: [PATCH] [skip e2e]Fix datanode compaction variable typo error (#13630) Signed-off-by: godchen0212 --- internal/datacoord/compaction.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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