org.apache.oozie.service

Class AbandonedCoordCheckerService

java.lang.Object

org.apache.oozie.service.AbandonedCoordCheckerService

All Implemented Interfaces:

Service

public class AbandonedCoordCheckerService
extends Object
implements Service

The Abandoned Coord Checker Service check finds out the abandoned coord jobs in system and kills it. A job is considered to be abandoned/faulty if total number of actions in failed/timedout/suspended >= limit and there are no succeeded action and job start time < job.older.than. Email will not be sent if oozie.service.AbandonedCoordCheckerService.email.address is not configured.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbandonedCoordCheckerService.AbandonedCoordCheckerRunnable

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONF_CHECK_DELAY
static String	CONF_CHECK_INTERVAL
static String	CONF_FAILURE_LEN
static String	CONF_JOB_KILL
static String	CONF_JOB_OLDER_THAN
static String	OOZIE_BASE_URL
static String	TO_ADDRESS

Fields inherited from interface org.apache.oozie.service.Service

DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
AbandonedCoordCheckerService()

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy() Destroy the service.
Class<? extends Service>	getInterface() Return the public interface of the service.
void	init(Services services) Initialize the service.

Methods inherited from class java.lang.Object

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

Field Detail

TO_ADDRESS

public static final String TO_ADDRESS

See Also:

Constant Field Values

CONF_CHECK_INTERVAL

public static final String CONF_CHECK_INTERVAL

See Also:

Constant Field Values

CONF_CHECK_DELAY

public static final String CONF_CHECK_DELAY

See Also:

Constant Field Values

CONF_FAILURE_LEN

public static final String CONF_FAILURE_LEN

See Also:

Constant Field Values

CONF_JOB_OLDER_THAN

public static final String CONF_JOB_OLDER_THAN

See Also:

Constant Field Values

CONF_JOB_KILL

public static final String CONF_JOB_KILL

See Also:

Constant Field Values

OOZIE_BASE_URL

public static final String OOZIE_BASE_URL

See Also:

Constant Field Values

Constructor Detail

AbandonedCoordCheckerService

public AbandonedCoordCheckerService()

Method Detail

init

public void init(Services services)

Description copied from interface: Service

Initialize the service.

Invoked by the Service singleton at start up time.

Specified by:

init in interface Service

Parameters:

services - services singleton initializing the service.

destroy

public void destroy()

Description copied from interface: Service

Destroy the service.

Invoked by the Service singleton at shutdown time.

Specified by:

destroy in interface Service

getInterface

public Class<? extends Service> getInterface()

Description copied from interface: Service

Return the public interface of the service.

Services are retrieved by its public interface. Specializations of services must return the public interface.

Specified by:

getInterface in interface Service

Returns:

the interface of the service.