Fix the bug of getting the wrong current flow QPS in ClusterFlowCheck…

…er (#972)
alibaba · Aug 12, 2019 · 17365f3 · 17365f3
1 parent 56c7369
commit 17365f3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...erver-default/src/main/java/com/alibaba/csp/sentinel/cluster/flow/ClusterFlowChecker.java b/...erver-default/src/main/java/com/alibaba/csp/sentinel/cluster/flow/ClusterFlowChecker.java
@@ -64,7 +64,7 @@ static TokenResult acquireClusterToken(/*@Valid*/ FlowRule rule, int acquireCoun
             return new TokenResult(TokenResultStatus.FAIL);
         }
 
-        double latestQps = metric.getAvg(ClusterFlowEvent.PASS_REQUEST);
+        double latestQps = metric.getAvg(ClusterFlowEvent.PASS);
         double globalThreshold = calcGlobalThreshold(rule) * ClusterServerConfigManager.getExceedCount();
         double nextRemaining = globalThreshold - latestQps - acquireCount;