From 7c689df81268d6cc49df411727d55d6976cab14c Mon Sep 17 00:00:00 2001 From: SJC <88550136+sjcsjc123@users.noreply.github.com> Date: Mon, 15 Jan 2024 10:11:38 +0800 Subject: [PATCH] fix: bug with repeat key (#2306) * fix bug with repeat key Signed-off-by: sjcsjc123 <1401189096@qq.com> --- tools/pika_keys_analysis/pika.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tools/pika_keys_analysis/pika.go b/tools/pika_keys_analysis/pika.go index 47a7cf5eaf..72003a53bc 100644 --- a/tools/pika_keys_analysis/pika.go +++ b/tools/pika_keys_analysis/pika.go @@ -101,6 +101,8 @@ func SolveSingleClient(client *redis.Client, ctx context.Context, wg *sync.WaitG } } }(cursor) + cursor += int64(ScanSize) + start = true keys, _, err := client.Scan(ctx, uint64(cursor), "*", 1).Result() if err != nil { _ = fmt.Errorf("scan error: %s", err) @@ -111,8 +113,6 @@ func SolveSingleClient(client *redis.Client, ctx context.Context, wg *sync.WaitG break } } - cursor += int64(ScanSize) - start = true } fmt.Printf("Current client %s done, waiting for task to finish\n", client) wgClient.Wait()