client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(hostname), port));
} catch (final Exception e) {
throw new CrawlerSystemException("Unknown host: " + address);
}
logger.info("Connected to " + hostname + ":" + port);
<BUG>});
final ClusterHealthResponse healthResponse =
ActionGetUtil.actionGet(client.admin().cluster().prepareHealth().setWaitForYellowStatus().execute());</BUG>
if (!healthResponse.isTimedOut()) {
onConnectListenerList.forEach(l -> {

client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(hostname), port));
} catch (final Exception e) {
throw new CrawlerSystemException("Unknown host: " + address);
}
logger.info("Connected to " + hostname + ":" + port);
});
final ClusterHealthResponse healthResponse = get(c -> c.admin().cluster().prepareHealth().setWaitForYellowStatus().execute());
if (!healthResponse.isTimedOut()) {
onConnectListenerList.forEach(l -> {
