Fix consumer side call DefaultExecutorRepository#getExecutor method c…

…annot hit the cache when use the service discovery pattern (#7717)
apache · May 11, 2021 · cafd8c4 · cafd8c4
1 parent 4fe06ec
commit cafd8c4
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/InstanceAddressURL.java b/...dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/InstanceAddressURL.java
@@ -29,6 +29,8 @@
 import static org.apache.dubbo.common.constants.CommonConstants.INTERFACE_KEY;
 import static org.apache.dubbo.common.constants.CommonConstants.REMOTE_APPLICATION_KEY;
 import static org.apache.dubbo.common.constants.CommonConstants.VERSION_KEY;
+import static org.apache.dubbo.common.constants.CommonConstants.SIDE_KEY;
+import static org.apache.dubbo.common.constants.CommonConstants.CONSUMER_SIDE;
 
 public class InstanceAddressURL extends URL {
     private ServiceInstance instance;
@@ -108,6 +110,8 @@ public String getParameter(String key) {
             return getServiceInterface();
         } else if (REMOTE_APPLICATION_KEY.equals(key)) {
             return instance.getServiceName();
+        } else if (SIDE_KEY.equals(key)) {
+            return CONSUMER_SIDE;
         }
 
         String protocolServiceKey = getProtocolServiceKey();