L282: final PingResponse pingResponse = searchEngineClient.ping(); L283: writeJsonResponse(pingResponse.getStatus() == 0 ? HttpServletResponse.SC_OK : HttpServletResponse.SC_SERVICE_UNAVAILABLE, L284: "\"data\":" + pingResponse.getMessage()); L285: } catch (final Exception e) { L286: if (logger.isDebugEnabled()) { L287: logger.debug("Failed to process a ping request.", e); L288: } L289: writeJsonRespons...

Exception e) { L1216: logger.error(() -> "Failed to flush " + stream(indices).get(stream -> stream.collect(Collectors.joining(", "))), e); L1217: } L1218: }); L1219: L1220: } L1221: L1222: public PingResponse ping() { L1223: try { L1224: final ClusterHealthResponse response = L1225: client.admin().cluster().prepareHealth().execute().actionGet(ComponentUtil.getFessConfig().getIndexHealthTimeout()); L1226: return...