diff --git a/dubbo-cluster/src/main/java/com/alibaba/dubbo/rpc/cluster/support/BroadcastClusterInvoker.java b/dubbo-cluster/src/main/java/com/alibaba/dubbo/rpc/cluster/support/BroadcastClusterInvoker.java index 9e10670505..e5d7412120 100644 --- a/dubbo-cluster/src/main/java/com/alibaba/dubbo/rpc/cluster/support/BroadcastClusterInvoker.java +++ b/dubbo-cluster/src/main/java/com/alibaba/dubbo/rpc/cluster/support/BroadcastClusterInvoker.java @@ -17,6 +17,8 @@ package com.alibaba.dubbo.rpc.cluster.support; import java.util.List; +import com.alibaba.dubbo.common.logger.Logger; +import com.alibaba.dubbo.common.logger.LoggerFactory; import com.alibaba.dubbo.rpc.Invocation; import com.alibaba.dubbo.rpc.Invoker; import com.alibaba.dubbo.rpc.Result; @@ -30,7 +32,9 @@ import com.alibaba.dubbo.rpc.cluster.LoadBalance; * * @author william.liangf */ -public class BroadcastClusterInvoker extends AbstractClusterInvoker{ +public class BroadcastClusterInvoker extends AbstractClusterInvoker { + + private static final Logger logger = LoggerFactory.getLogger(BroadcastClusterInvoker.class); public BroadcastClusterInvoker(Directory directory) { super(directory); @@ -47,6 +51,10 @@ public class BroadcastClusterInvoker extends AbstractClusterInvoker{ result = invoker.invoke(invocation); } catch (RpcException e) { exception = e; + logger.warn(e.getMessage(), e); + } catch (Throwable e) { + exception = new RpcException(e.getMessage(), e); + logger.warn(e.getMessage(), e); } } if (exception != null) {