From 449e940d946124dee9ff1307324567efc81255f5 Mon Sep 17 00:00:00 2001
From: cserwen <cserwen@163.com>
Date: Sat, 7 May 2022 16:58:23 +0800
Subject: [PATCH] fix queueMaxSpanFlowControlTimes not change

---
 consumer/push_consumer.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
index 3f4d7a02..5a9f64af 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -623,6 +623,7 @@ func (pc *pushConsumer) pullMessage(request *PullRequest) {
 						rlog.LogKeyPullRequest:       request.String(),
 					})
 				}
+				pc.queueMaxSpanFlowControlTimes++
 				sleepTime = _PullDelayTimeWhenFlowControl
 				goto NEXT
 			}