org.apache.flink.streaming.connectors.elasticsearch.util

Class RetryRejectedExecutionFailureHandler

java.lang.Object

org.apache.flink.streaming.connectors.elasticsearch.util.RetryRejectedExecutionFailureHandler

All Implemented Interfaces:

Serializable, ActionRequestFailureHandler

@PublicEvolving
public class RetryRejectedExecutionFailureHandler
extends Object
implements ActionRequestFailureHandler

An ActionRequestFailureHandler that re-adds requests that failed due to temporary EsRejectedExecutionExceptions (which means that Elasticsearch node queues are currently full), and fails for all other failures.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RetryRejectedExecutionFailureHandler()

Method Summary

Modifier and Type	Method and Description
void	onFailure(org.elasticsearch.action.ActionRequest action, Throwable failure, int restStatusCode, RequestIndexer indexer) Handle a failed ActionRequest.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RetryRejectedExecutionFailureHandler

public RetryRejectedExecutionFailureHandler()

Method Detail

onFailure

public void onFailure(org.elasticsearch.action.ActionRequest action,
                      Throwable failure,
                      int restStatusCode,
                      RequestIndexer indexer)
               throws Throwable

Description copied from interface: ActionRequestFailureHandler

Handle a failed ActionRequest.

Specified by:

onFailure in interface ActionRequestFailureHandler

Parameters:

action - the ActionRequest that failed due to the failure

failure - the cause of failure

restStatusCode - the REST status code of the failure (-1 if none can be retrieved)

indexer - request indexer to re-add the failed action, if intended to do so

Throws:

Throwable - if the sink should fail on this failure, the implementation should rethrow the exception or a custom one