This is an automated email from the ASF dual-hosted git repository.

songxiaosheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-spi-extensions.git


The following commit(s) were added to refs/heads/master by this push:
     new 40ee1f2  fix:npe (#400)
40ee1f2 is described below

commit 40ee1f27bdf09ef79875f22fd331728afedd4df6
Author: 其一 <[email protected]>
AuthorDate: Fri Jun 7 21:48:40 2024 +0800

    fix:npe (#400)
    
    Co-authored-by: 其一 <[email protected]>
---
 .../org/apache/dubbo/rpc/cluster/support/BroadcastCluster1Invoker.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/dubbo-cluster-extensions/dubbo-cluster-broadcast-1/src/main/java/org/apache/dubbo/rpc/cluster/support/BroadcastCluster1Invoker.java
 
b/dubbo-cluster-extensions/dubbo-cluster-broadcast-1/src/main/java/org/apache/dubbo/rpc/cluster/support/BroadcastCluster1Invoker.java
index b0470ae..ef42514 100644
--- 
a/dubbo-cluster-extensions/dubbo-cluster-broadcast-1/src/main/java/org/apache/dubbo/rpc/cluster/support/BroadcastCluster1Invoker.java
+++ 
b/dubbo-cluster-extensions/dubbo-cluster-broadcast-1/src/main/java/org/apache/dubbo/rpc/cluster/support/BroadcastCluster1Invoker.java
@@ -118,7 +118,7 @@ public class BroadcastCluster1Invoker<T> extends 
AbstractClusterInvoker<T> {
                     br.setResult(result);
                 }
             } catch (Throwable ex) {
-                RpcException exception = 
getRpcException(result.getException());
+                RpcException exception = getRpcException(result == null ? ex : 
result.getException());
                 br.setExceptionMsg(exception.getMessage());
                 br.setException(exception);
                 logger.warn(exception.getMessage(), exception);

Reply via email to