diff --git a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/migration/MigrationRuleHandler.java b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/migration/MigrationRuleHandler.java index ab802f848a..cc79a07879 100644 --- a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/migration/MigrationRuleHandler.java +++ b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/migration/MigrationRuleHandler.java @@ -57,7 +57,7 @@ public class MigrationRuleHandler { try { rule = MigrationRule.parse(rawRule); // FIXME, consumerURL.getHost() might not exactly the ip expected. - if (rule.getTargetIps() != null && rule.getTargetIps().contains(consumerURL.getHost())) { + if (rule.getTargetIps() == null || (rule.getTargetIps() != null && rule.getTargetIps().contains(consumerURL.getHost()))) { setMigrationRule(rule); step = rule.getStep(consumerURL.getServiceKey()); threshold = rule.getThreshold(consumerURL.getServiceKey());