public static Schema getSchema()

in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/RestService.java [284:301]

• 18 lines of code
• 3 McCabe index (conditional complexity)

    public static Schema getSchema(Settings cfg, Logger logger)
            throws DorisException {
        logger.trace("Finding schema.");
        List<String> feNodeList = allEndpoints(cfg.getProperty(DORIS_FENODES), logger);
        for (String feNode: feNodeList) {
            try {
                HttpGet httpGet = new HttpGet(getUriStr(feNode,cfg, logger) + SCHEMA);
                String response = send(cfg, httpGet, logger);
                logger.debug("Find schema response is '{}'.", response);
                return parseSchema(response, logger);
            } catch (ConnectedFailedException e) {
                logger.info("Doris FE node {} is unavailable: {}, Request the next Doris FE node", feNode, e.getMessage());
            }
        }
        String errMsg = "No Doris FE is available, please check configuration";
        logger.error(errMsg);
        throw new DorisException(errMsg);
    }