Update for no endpoint scene

jd-opensource · Jan 23, 2025 · 7d46b24 · 7d46b24
1 parent f8a7e10
commit 7d46b24
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...grpc/src/main/java/com/jd/live/agent/plugin/router/gprc/loadbalance/LiveLoadBalancer.java b/...grpc/src/main/java/com/jd/live/agent/plugin/router/gprc/loadbalance/LiveLoadBalancer.java
@@ -82,7 +82,8 @@ public void handleResolvedAddresses(ResolvedAddresses resolvedAddresses) {
 
     @Override
     public void handleNameResolutionError(Status error) {
-        helper.updateBalancingState(TRANSIENT_FAILURE, new LiveSubchannelPicker(PickResult.withError(error)));
+//        helper.updateBalancingState(TRANSIENT_FAILURE, new LiveSubchannelPicker(PickResult.withError(error)));
+        handleResolvedAddresses(null);
     }
 
     @Override
@@ -123,6 +124,9 @@ protected static String getServiceName(Helper helper) {
      */
     private Set<EquivalentAddressGroup> deDup(ResolvedAddresses resolvedAddresses) {
         Set<EquivalentAddressGroup> result = new HashSet<>();
+        if (resolvedAddresses == null) {
+            return result;
+        }
         resolvedAddresses.getAddresses().forEach(addressGroup -> {
             Attributes attributes = addressGroup.getAttributes();
             addressGroup.getAddresses().forEach(address -> result.add(new EquivalentAddressGroup(address, attributes)));