diff --git a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/loadbalance/ShortestResponseLoadBalance.java b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/loadbalance/ShortestResponseLoadBalance.java index 610b1b4e336..5836884b5cc 100644 --- a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/loadbalance/ShortestResponseLoadBalance.java +++ b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/loadbalance/ShortestResponseLoadBalance.java @@ -61,7 +61,7 @@ protected Invoker doSelect(List> invokers, URL url, Invocation RpcStatus rpcStatus = RpcStatus.getStatus(invoker.getUrl(), invocation.getMethodName()); // Calculate the estimated response time from the product of active connections and succeeded average elapsed time. long succeededAverageElapsed = rpcStatus.getSucceededAverageElapsed(); - int active = rpcStatus.getActive(); + int active = rpcStatus.getActive() + 1; long estimateResponse = succeededAverageElapsed * active; int afterWarmup = getWeight(invoker, invocation); weights[i] = afterWarmup;