update check condition

pingcap · May 24, 2019 · 3f87142 · 3f87142
1 parent 8a85643
commit 3f87142
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pump/storage/storage.go b/pump/storage/storage.go
@@ -554,6 +554,7 @@ func (a *Append) doGCTS(ts int64) {
 		if stats.LevelTablesCounts[0] >= l0Trigger {
 			log.Info("wait some time to gc cause too many L0 file", stats.LevelTablesCounts[0])
 			time.Sleep(5 * time.Second)
+			continue
 		}
 
 		irange := &util.Range{
@@ -575,7 +576,9 @@ func (a *Append) doGCTS(ts int64) {
 			}
 		}
 
-		if !iter.Next() {
+		iter.Release()
+
+		if deleteBatch < 100 {
 			if batch.Len() > 0 {
 				err := a.metadata.Write(batch, nil)
 				if err != nil {