Merge pull request #824 from cserwen/fix_flow

fix queueMaxSpanFlowControlTimes not change
apache · May 10, 2022 · 0189e44 · 0189e44
2 parents 853f304 + 449e940
commit 0189e44
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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
 			}