org.apache.reef.client

Class DriverRestartConfiguration

java.lang.Object

org.apache.reef.tang.formats.ConfigurationModuleBuilder

org.apache.reef.client.DriverRestartConfiguration

public final class DriverRestartConfiguration
extends ConfigurationModuleBuilder

EventHandlers specific to Driver Restart. Please remember to bind a runtime-specific DriverRestartConfiguration, e.g. YarnDriverRestartConfiguration.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigurationModule	CONF
static OptionalParameter<Integer>	DRIVER_RESTART_EVALUATOR_RECOVERY_SECONDS The amount of time in seconds the driver waits for evaluators to report back on restart.
static OptionalParameter<Boolean>	FAIL_DRIVER_ON_EVALUATOR_LOG_ERROR Parameter to determine whether the driver should fail or continue if there are evaluator preservation log failures.
static OptionalImpl<EventHandler<DriverRestartCompleted>>	ON_DRIVER_RESTART_COMPLETED Event handler for the event of driver restart completion, default to logging if not bound.
static OptionalImpl<EventHandler<ActiveContext>>	ON_DRIVER_RESTART_CONTEXT_ACTIVE Event handler for active context when driver restart.
static OptionalImpl<EventHandler<FailedEvaluator>>	ON_DRIVER_RESTART_EVALUATOR_FAILED Event handler for the event of driver restart completion, default to logging if not bound.
static OptionalImpl<EventHandler<RunningTask>>	ON_DRIVER_RESTART_TASK_RUNNING Event handler for running tasks in previous evaluator, when driver restarted.
static OptionalImpl<EventHandler<DriverRestarted>>	ON_DRIVER_RESTARTED This event is fired in place of the ON_DRIVER_STARTED when the Driver is in fact restarted after failure.

Method Summary

Methods inherited from class org.apache.reef.tang.formats.ConfigurationModuleBuilder

bind, bindConstructor, bindConstructor, bindImplementation, bindImplementation, bindImplementation, bindList, bindList, bindList, bindNamedParameter, bindNamedParameter, bindNamedParameter, bindNamedParameter, bindSetEntry, bindSetEntry, bindSetEntry, bindSetEntry, build, merge

Methods inherited from class java.lang.Object

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

Field Detail

ON_DRIVER_RESTARTED

public static final OptionalImpl<EventHandler<DriverRestarted>> ON_DRIVER_RESTARTED

This event is fired in place of the ON_DRIVER_STARTED when the Driver is in fact restarted after failure.

ON_DRIVER_RESTART_TASK_RUNNING

public static final OptionalImpl<EventHandler<RunningTask>> ON_DRIVER_RESTART_TASK_RUNNING

Event handler for running tasks in previous evaluator, when driver restarted. Defaults to crash if not bound.

ON_DRIVER_RESTART_CONTEXT_ACTIVE

public static final OptionalImpl<EventHandler<ActiveContext>> ON_DRIVER_RESTART_CONTEXT_ACTIVE

Event handler for active context when driver restart. Defaults to closing the context if not bound.

ON_DRIVER_RESTART_COMPLETED

public static final OptionalImpl<EventHandler<DriverRestartCompleted>> ON_DRIVER_RESTART_COMPLETED

Event handler for the event of driver restart completion, default to logging if not bound.

ON_DRIVER_RESTART_EVALUATOR_FAILED

public static final OptionalImpl<EventHandler<FailedEvaluator>> ON_DRIVER_RESTART_EVALUATOR_FAILED

Event handler for the event of driver restart completion, default to logging if not bound.

DRIVER_RESTART_EVALUATOR_RECOVERY_SECONDS

public static final OptionalParameter<Integer> DRIVER_RESTART_EVALUATOR_RECOVERY_SECONDS

The amount of time in seconds the driver waits for evaluators to report back on restart. Defaults to 3 minutes. If the value is set to Integer.MAX_VALUE, the driver will wait forever.

FAIL_DRIVER_ON_EVALUATOR_LOG_ERROR

public static final OptionalParameter<Boolean> FAIL_DRIVER_ON_EVALUATOR_LOG_ERROR

Parameter to determine whether the driver should fail or continue if there are evaluator preservation log failures. Defaults to false.

CONF

public static final ConfigurationModule CONF