From cee31e915888725c6b9b2f93b93d15495779d1c2 Mon Sep 17 00:00:00 2001
From: Martin Sumner <martin.sumner@adaptip.co.uk>
Date: Fri, 21 Jul 2023 11:39:45 +0100
Subject: [PATCH] Reset deferred queue length on change

---
 src/riak_kv_replrtq_snk.erl | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/riak_kv_replrtq_snk.erl b/src/riak_kv_replrtq_snk.erl
index cd026b8e2..dbfb4949e 100644
--- a/src/riak_kv_replrtq_snk.erl
+++ b/src/riak_kv_replrtq_snk.erl
@@ -347,6 +347,7 @@ handle_call({worker_count, QueueN, WorkerCount, PerPeerLimit}, _From, State) ->
             SinkWork0 =
                 SinkWork#sink_work{work_queue = WorkQueue,
                                     minimum_queue_length = QueueLength,
+                                    deferred_queue_length = 0,
                                     max_worker_count = WorkerCount},
             W0 =
                 lists:keyreplace(QueueN, 1, State#state.work,