add throw Exception

WeDataSphere · Mar 22, 2024 · 4271195 · 4271195
1 parent 72ac28d
commit 4271195
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/...src/main/java/org/apache/linkis/rpc/loadbalancer/ServiceInstancePriorityLoadBalancer.java b/...src/main/java/org/apache/linkis/rpc/loadbalancer/ServiceInstancePriorityLoadBalancer.java
@@ -109,7 +109,7 @@ private Response<ServiceInstance> processInstanceResponse(
             : null;
 
     while (null == serviceInstanceResponse
-        && StringUtils.isNoneBlank(clientIp)
+        && StringUtils.isNotBlank(clientIp)
         && isRPC(linkisLoadBalancerType)
         && System.currentTimeMillis() < endTtime) {
       cacheManualRefresher.refresh();
@@ -120,11 +120,17 @@ && isRPC(linkisLoadBalancerType)
         try {
           Thread.sleep(5000L);
         } catch (InterruptedException e) {
-          throw new RuntimeException(e);
+
         }
       }
     }
 
+    if (null == serviceInstanceResponse && StringUtils.isNotBlank(clientIp)) {
+      throw new NoInstanceExistsException(
+              LinkisRpcErrorCodeSummary.INSTANCE_ERROR.getErrorCode(),
+              MessageFormat.format(LinkisRpcErrorCodeSummary.INSTANCE_ERROR.getErrorDesc(), clientIp));
+    }
+
     if (supplier instanceof SelectedInstanceCallback && serviceInstanceResponse.hasServer()) {
       ((SelectedInstanceCallback) supplier)
           .selectedServiceInstance(serviceInstanceResponse.getServer());