diff --git a/polaris-plugins/polaris-plugins-circuitbreaker/circuitbreaker-composite/src/main/java/com/tencent/polaris/plugins/circuitbreaker/composite/PolarisCircuitBreaker.java b/polaris-plugins/polaris-plugins-circuitbreaker/circuitbreaker-composite/src/main/java/com/tencent/polaris/plugins/circuitbreaker/composite/PolarisCircuitBreaker.java index 2f7c31f60..1b2ac668a 100644 --- a/polaris-plugins/polaris-plugins-circuitbreaker/circuitbreaker-composite/src/main/java/com/tencent/polaris/plugins/circuitbreaker/composite/PolarisCircuitBreaker.java +++ b/polaris-plugins/polaris-plugins-circuitbreaker/circuitbreaker-composite/src/main/java/com/tencent/polaris/plugins/circuitbreaker/composite/PolarisCircuitBreaker.java @@ -113,7 +113,7 @@ public CircuitBreakerStatus checkResource(Resource resource) { Resource ruleResource = getActualResource(resource); Optional resourceCounters = getResourceCounters(ruleResource); if (null == resourceCounters) { - if (resource.getLevel() == Level.METHOD && ruleResource == resource) { + if (resource.getLevel() == Level.METHOD && Objects.equals(ruleResource, resource)) { // 可能是被淘汰了,需要重新计算RuleResource CircuitBreakerProto.CircuitBreakerRule circuitBreakerRule = circuitBreakerRuleDictionary.lookupCircuitBreakerRule(resource); ruleResource = computeResourceByRule(resource, circuitBreakerRule);