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 }