delete invalid code

apache · Jan 29, 2024 · cba495d · cba495d
1 parent eeef261
commit cba495d
Showing 1 changed file with 1 addition and 7 deletions.
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java
@@ -275,7 +275,6 @@ static String[] parseIdentifier(String tableIdentifier, Logger logger)
     public static String randomEndpoint(String feNodes, Logger logger)
             throws IllegalArgumentException {
         logger.trace("Parse fenodes '{}'.", feNodes);
-        int checkCount = 0;
         if (StringUtils.isEmpty(feNodes)) {
             logger.error(ILLEGAL_ARGUMENT_MESSAGE, "fenodes", feNodes);
             throw new IllegalArgumentException("fenodes", feNodes);
@@ -285,14 +284,9 @@ public static String randomEndpoint(String feNodes, Logger logger)
         for (String feNode : nodes) {
             if (BackendUtil.tryHttpConnection(feNode)) {
                 return feNode;
-            } else {
-                ++checkCount;
             }
         }
-        if (checkCount >= nodes.size()) {
-            throw new DorisRuntimeException("No Doris FE is available, please check configuration");
-        }
-        return null;
+        throw new DorisRuntimeException("No Doris FE is available, please check configuration or cluster status.");
     }
 
     /**