add metrics and fix iter release

pingcap · Aug 19, 2019 · 3af2f9c · 3af2f9c
1 parent 5f2ae90
commit 3af2f9c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pump/storage/storage.go b/pump/storage/storage.go
@@ -667,7 +667,6 @@ func (a *Append) doGCTS(ts int64) {
 	iter := a.metadata.NewIterator(irange, nil)
 
 	for {
-		deleteBatch := 0
 
 		nStr, err := a.metadata.GetProperty("leveldb.num-files-at-level0")
 		if err != nil {
@@ -687,6 +686,7 @@ func (a *Append) doGCTS(ts int64) {
 			continue
 		}
 
+		deleteBatch := 0
 		var lastKey []byte
 
 		for iter.Next() && deleteBatch < 100 {