@Override
	public void onFailure(ActionRequest action, Throwable failure, int restStatusCode, RequestIndexer indexer) throws Throwable {
		// simply fail the sink
		throw failure;
	}
An {@link ActionRequestFailureHandler} that simply fails the sink on any failures.
elasticsearch5-xh/elasticsearch5-xh-sink/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/NoOpFailureHandler.java