From d1c0ddc362430faff3350cfabb7fc0b70356efc4 Mon Sep 17 00:00:00 2001
From: Lyon Hill <lyondhill@gmail.com>
Date: Fri, 24 Jan 2020 09:46:01 -0700
Subject: [PATCH] fix(kv): update kv source to use the new forward cursor
 (#16659)

---
 kv/source.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/kv/source.go b/kv/source.go
index fb07843e81..03486b732d 100644
--- a/kv/source.go
+++ b/kv/source.go
@@ -238,12 +238,12 @@ func (s *Service) forEachSource(ctx context.Context, tx Tx, fn func(*influxdb.So
 		return err
 	}
 
-	cur, err := b.Cursor()
+	cur, err := b.ForwardCursor(nil)
 	if err != nil {
 		return err
 	}
 
-	for k, v := cur.First(); k != nil; k, v = cur.Next() {
+	for k, v := cur.Next(); k != nil; k, v = cur.Next() {
 		s := &influxdb.Source{}
 		if err := json.Unmarshal(v, s); err != nil {
 			return err