in spark-doris-connector/src/main/java/org/apache/doris/spark/serialization/Routing.java [39:53]
private void parseRouting(String routing) throws IllegalArgumentException {
logger.debug("Parse Doris BE address: '{}'.", routing);
String[] hostPort = routing.split(":");
if (hostPort.length != 2) {
logger.error("Format of Doris BE address '{}' is illegal.", routing);
throw new IllegalArgumentException("Doris BE", routing);
}
this.host = hostPort[0];
try {
this.port = Integer.parseInt(hostPort[1]);
} catch (NumberFormatException e) {
logger.error(PARSE_NUMBER_FAILED_MESSAGE, "Doris BE's port", hostPort[1]);
throw new IllegalArgumentException("Doris BE", routing);
}
}