test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-01 03:18:29 +08:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

[skip e2e]Fix datanode compaction variable typo error (#13630)

Browse Source 
Signed-off-by: godchen0212 <qingxiang.chen@zilliz.com>
This commit is contained in:
godchen 2021-12-17 19:14:59 +08:00 committed by GitHub
parent d382d596da
commit e36f7287ae
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/datacoord/compaction.go
View File

@ -254,9 +254,9 @@ func (c *compactionPlanHandler) expireCompaction(ts Timestamp) error {
} }
func (c *compactionPlanHandler) isTimeout(now Timestamp, start Timestamp, timeout int32) bool { func (c *compactionPlanHandler) isTimeout(now Timestamp, start Timestamp, timeout int32) bool {
starttime, _ := tsoutil.ParseTS(start) startTime, _ := tsoutil.ParseTS(start)
ts, _ := tsoutil.ParseTS(now) 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 // isFull return true if the task pool is full