https://github.com/apache/dubbo/issues/12615

Fixing unlogged exceptions in MergeableClusterInvoker
apache · Jul 6, 2023 · ccfe663 · ccfe663
1 parent 1f84cdc
commit ccfe663
Showing 1 changed file with 19 additions and 2 deletions.
diff --git a/...o-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/MergeableClusterInvoker.java b/...o-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/MergeableClusterInvoker.java
@@ -73,7 +73,16 @@ protected Result doInvoke(Invocation invocation, List<Invoker<T>> invokers, Load
                     }
                 }
             }
-            return invokers.iterator().next().invoke(invocation);
+            Invoker<T>  invoker = invokers.iterator().next();
+			try {
+            	return invoker.invoke(invocation);
+            } catch (RpcException e) {
+                if (e.isNoInvokerAvailableAfterFilter()) {
+                    log.debug("No available provider for service" + getUrl().getServiceKey() + " on group " + invoker.getUrl().getParameter(GROUP_KEY) + ", will continue to try another group.");
+                } else {
+                    throw e;
+                }
+            }
         }
 
         Class<?> returnType;
@@ -88,7 +97,15 @@ protected Result doInvoke(Invocation invocation, List<Invoker<T>> invokers, Load
         for (final Invoker<T> invoker : invokers) {
             RpcInvocation subInvocation = new RpcInvocation(invocation, invoker);
             subInvocation.setAttachment(ASYNC_KEY, "true");
-            results.put(invoker.getUrl().getServiceKey(), invoker.invoke(subInvocation));
+            try {
+            	results.put(invoker.getUrl().getServiceKey(), invoker.invoke(subInvocation));
+            } catch (RpcException e) {
+                if (e.isNoInvokerAvailableAfterFilter()) {
+                    log.debug("No available provider for service" + getUrl().getServiceKey() + " on group " + invoker.getUrl().getParameter(GROUP_KEY) + ", will continue to try another group.");
+                } else {
+                    throw e;
+                }
+            }
         }
 
         Object result = null;