Uses of Class
org.apache.oozie.command.CommandException

Packages that use CommandException

org.apache.oozie
org.apache.oozie.command
org.apache.oozie.command.bundle
org.apache.oozie.command.coord
org.apache.oozie.command.wf
org.apache.oozie.coord
org.apache.oozie.dependency
org.apache.oozie.sla
org.apache.oozie.util
org.apache.oozie.util.db

Uses of CommandException in org.apache.oozie

Methods in org.apache.oozie that throw CommandException

void	CoordinatorEngine.streamLog(String jobId, String logRetrievalScope, String logRetrievalType, Writer writer) Add list of actions to the filter based on conditions

Uses of CommandException in org.apache.oozie.command

Methods in org.apache.oozie.command that throw CommandException

T	XCommand.call() Implements the XCommand life-cycle.
T	Command.call() Execute the command #call(WorkflowStore) setting all the necessary context.
protected abstract T	Command.call(S store) DagCallable subclasses must implement this method to perform their task.
protected void	XCommand.eagerLoadState() Load the necessary state to perform an eager precondition check.
protected void	RerunTransitionXCommand.eagerLoadState()
protected void	XCommand.eagerVerifyPrecondition() Verify the precondition for the command before obtaining a lock.
protected void	RerunTransitionXCommand.eagerVerifyPrecondition()
protected abstract T	XCommand.execute() Command execution body.
protected Void	UnpauseTransitionXCommand.execute()
protected T	TransitionXCommand.execute()
protected Void	SuspendTransitionXCommand.execute()
protected String	SubmitTransitionXCommand.execute()
protected Void	StartTransitionXCommand.execute()
protected Void	ResumeTransitionXCommand.execute()
protected T	RerunTransitionXCommand.execute()
protected Void	PurgeXCommand.execute()
protected Void	PauseTransitionXCommand.execute()
protected Void	MaterializeTransitionXCommand.execute()
protected Void	KillTransitionXCommand.execute()
protected BulkResponseInfo	BulkJobsXCommand.execute()
protected T	Command.execute(S store)
void	TransitionXCommand.generateEvents(CoordinatorJobBean coordJob) This will be used to generate Job Notification events on status changes
abstract void	KillTransitionXCommand.killChildren()
protected abstract void	XCommand.loadState() Load the necessary state to perform the precondition check and to execute the command.
protected void	PurgeXCommand.loadState()
protected void	BulkJobsXCommand.loadState()
protected abstract void	MaterializeTransitionXCommand.materialize() Materialize the actions for current job
abstract void	TransitionXCommand.notifyParent() This will be used to notify the parent about the status of that perticular job.
abstract void	PauseTransitionXCommand.pauseChildren() pause actions associated with the job
abstract void	TransitionXCommand.performWrites() This will be used to perform atomically all the writes within this command.
abstract void	RerunTransitionXCommand.rerunChildren() Rerun actions associated with the job
abstract void	ResumeTransitionXCommand.resumeChildren() Resume all children of the job
abstract void	StartTransitionXCommand.StartChildren() Start actions associated with the job
protected abstract String	SubmitTransitionXCommand.submit() Submit the job
abstract void	SuspendTransitionXCommand.suspendChildren() Suspend all children of the job
void	UnpauseTransitionXCommand.transitToNext()
abstract void	TransitionXCommand.transitToNext() Transit to the next status based on the result of the Job.
void	PauseTransitionXCommand.transitToNext()
void	MaterializeTransitionXCommand.transitToNext()
abstract void	UnpauseTransitionXCommand.unpauseChildren() Unpause actions associated with the job
abstract void	TransitionXCommand.updateJob() Update the parent job.
protected abstract void	XCommand.verifyPrecondition() Verify the precondition for the command after a lock has been obtain, just before executing the command.
protected void	RerunTransitionXCommand.verifyPrecondition()
protected void	PurgeXCommand.verifyPrecondition()
protected void	BulkJobsXCommand.verifyPrecondition()

Uses of CommandException in org.apache.oozie.command.bundle

Methods in org.apache.oozie.command.bundle that throw CommandException

protected void	BundleSubmitXCommand.eagerLoadState()
protected void	BundleStatusUpdateXCommand.eagerLoadState()
void	BundleStartXCommand.eagerLoadState()
protected void	BundleJobChangeXCommand.eagerLoadState()
protected void	BundleSubmitXCommand.eagerVerifyPrecondition()
protected void	BundleStartXCommand.eagerVerifyPrecondition()
protected void	BundleJobChangeXCommand.eagerVerifyPrecondition()
protected Void	BundleStatusUpdateXCommand.execute()
protected BundleJobBean	BundleJobXCommand.execute()
protected BundleJobInfo	BundleJobsXCommand.execute()
protected Void	BundleJobChangeXCommand.execute()
void	BundleKillXCommand.killChildren()
void	BundleUnpauseXCommand.loadState()
protected void	BundleSubmitXCommand.loadState()
protected void	BundleStatusUpdateXCommand.loadState()
void	BundleStartXCommand.loadState()
protected void	BundleRerunXCommand.loadState()
void	BundlePauseXCommand.loadState()
void	BundleKillXCommand.loadState()
protected void	BundleJobXCommand.loadState()
protected void	BundleJobsXCommand.loadState()
protected void	BundleJobSuspendXCommand.loadState()
protected void	BundleJobResumeXCommand.loadState()
protected void	BundleJobChangeXCommand.loadState()
protected void	BundleSubmitXCommand.mergeDefaultConfig() Merge default configuration with user-defined configuration.
void	BundleSubmitXCommand.notifyParent()
void	BundleRerunXCommand.notifyParent()
void	BundleJobSuspendXCommand.notifyParent()
void	BundleJobResumeXCommand.notifyParent()
void	BundlePauseXCommand.pauseChildren()
void	BundleUnpauseXCommand.performWrites()
void	BundleSubmitXCommand.performWrites()
void	BundleStartXCommand.performWrites()
void	BundleRerunXCommand.performWrites()
void	BundlePauseXCommand.performWrites()
void	BundleKillXCommand.performWrites()
void	BundleJobSuspendXCommand.performWrites()
void	BundleJobResumeXCommand.performWrites()
void	BundleRerunXCommand.rerunChildren()
void	BundleStartXCommand.StartChildren()
protected String	BundleSubmitXCommand.submit()
void	BundleJobSuspendXCommand.suspendChildren()
void	BundleUnpauseXCommand.unpauseChildren()
void	BundleUnpauseXCommand.updateJob()
void	BundleSubmitXCommand.updateJob()
void	BundleStartXCommand.updateJob()
void	BundlePauseXCommand.updateJob()
protected void	BundleUnpauseXCommand.verifyPrecondition()
protected void	BundleSubmitXCommand.verifyPrecondition()
protected void	BundleStatusUpdateXCommand.verifyPrecondition()
protected void	BundleStartXCommand.verifyPrecondition()
protected void	BundlePauseXCommand.verifyPrecondition()
protected void	BundleKillXCommand.verifyPrecondition()
protected void	BundleJobXCommand.verifyPrecondition()
protected void	BundleJobsXCommand.verifyPrecondition()
protected void	BundleJobSuspendXCommand.verifyPrecondition()
protected void	BundleJobResumeXCommand.verifyPrecondition()
protected void	BundleJobChangeXCommand.verifyPrecondition()

Constructors in org.apache.oozie.command.bundle that throw CommandException

BundleJobChangeXCommand(String id, String changeValue)

Uses of CommandException in org.apache.oozie.command.coord

Methods in org.apache.oozie.command.coord that throw CommandException

protected void	CoordMaterializeTransitionXCommand.calcMatdTime() Calculate startMatdTime and endMatdTime from job's start time if next materialized time is null
protected Void	CoordActionMaterializeCommand.call(CoordinatorStore store)
static void	CoordCommandUtils.checkIfBothSameType(String startInst, String endInst)
protected void	CoordPushDependencyCheckXCommand.eagerLoadState()
protected void	CoordActionUpdateXCommand.eagerLoadState()
protected void	CoordActionStartXCommand.eagerLoadState()
protected void	CoordRerunXCommand.eagerVerifyPrecondition()
protected void	CoordPushDependencyCheckXCommand.eagerVerifyPrecondition()
protected void	CoordActionUpdateXCommand.eagerVerifyPrecondition()
protected List<SLAEventBean>	SLAEventsXCommand.execute()
protected Void	CoordPushDependencyCheckXCommand.execute()
protected CoordinatorJobBean	CoordJobXCommand.execute()
protected CoordinatorJobInfo	CoordJobsXCommand.execute()
protected Void	CoordChangeXCommand.execute()
protected Void	CoordActionUpdateXCommand.execute()
protected Void	CoordActionUpdatePushMissingDependency.execute()
protected Void	CoordActionTimeOutXCommand.execute()
protected Void	CoordActionStartXCommand.execute()
protected Void	CoordActionReadyXCommand.execute()
protected Void	CoordActionNotificationXCommand.execute()
protected Void	CoordActionInputCheckXCommand.execute()
protected CoordinatorActionBean	CoordActionInfoXCommand.execute()
protected Void	CoordActionCheckXCommand.execute()
protected Void	CoordActionMaterializeCommand.execute(CoordinatorStore store)
static List<CoordinatorActionBean>	CoordRerunXCommand.getCoordActions(String rerunType, String jobId, String scope) Get the list of actions for a given coordinator job
void	CoordKillXCommand.killChildren()
protected void	SLAEventsXCommand.loadState()
void	CoordUnpauseXCommand.loadState()
protected void	CoordSuspendXCommand.loadState()
protected void	CoordSubmitXCommand.loadState()
protected void	CoordResumeXCommand.loadState()
protected void	CoordRerunXCommand.loadState()
protected void	CoordPushDependencyCheckXCommand.loadState()
void	CoordPauseXCommand.loadState()
protected void	CoordMaterializeTransitionXCommand.loadState()
protected void	CoordKillXCommand.loadState()
protected void	CoordJobXCommand.loadState()
protected void	CoordJobsXCommand.loadState()
protected void	CoordChangeXCommand.loadState()
protected void	CoordActionUpdateXCommand.loadState()
protected void	CoordActionTimeOutXCommand.loadState()
protected void	CoordActionStartXCommand.loadState()
protected void	CoordActionReadyXCommand.loadState()
protected void	CoordActionNotificationXCommand.loadState()
protected void	CoordActionInputCheckXCommand.loadState()
protected void	CoordActionInfoXCommand.loadState()
protected void	CoordActionCheckXCommand.loadState()
protected void	CoordMaterializeTransitionXCommand.materialize()
protected void	CoordSubmitXCommand.mergeDefaultConfig() Merge default configuration with user-defined configuration.
void	CoordUnpauseXCommand.notifyParent()
void	CoordSuspendXCommand.notifyParent()
void	CoordSubmitXCommand.notifyParent()
void	CoordResumeXCommand.notifyParent()
void	CoordRerunXCommand.notifyParent()
void	CoordPauseXCommand.notifyParent()
void	CoordMaterializeTransitionXCommand.notifyParent()
void	CoordKillXCommand.notifyParent()
protected void	CoordPushDependencyCheckXCommand.onAllPushDependenciesAvailable()
void	CoordPauseXCommand.pauseChildren()
void	CoordUnpauseXCommand.performWrites()
void	CoordSuspendXCommand.performWrites()
void	CoordSubmitXCommand.performWrites()
void	CoordResumeXCommand.performWrites()
void	CoordRerunXCommand.performWrites()
void	CoordPauseXCommand.performWrites()
void	CoordMaterializeTransitionXCommand.performWrites()
void	CoordKillXCommand.performWrites()
void	CoordRerunXCommand.rerunChildren()
void	CoordResumeXCommand.resumeChildren()
protected String	CoordSubmitXCommand.submit()
void	CoordSuspendXCommand.suspendChildren()
void	CoordMaterializeTransitionXCommand.transitToNext()
void	CoordUnpauseXCommand.unpauseChildren()
protected void	CoordPushDependencyCheckXCommand.updateCoordAction(CoordinatorActionBean coordAction, boolean isChangeInDependency)
void	CoordUnpauseXCommand.updateJob()
void	CoordSubmitXCommand.updateJob()
void	CoordPauseXCommand.updateJob()
void	CoordMaterializeTransitionXCommand.updateJob()
void	CoordKillXCommand.updateJob()
protected void	SLAEventsXCommand.verifyPrecondition()
protected void	CoordUnpauseXCommand.verifyPrecondition()
protected void	CoordSuspendXCommand.verifyPrecondition()
protected void	CoordSubmitXCommand.verifyPrecondition()
protected void	CoordResumeXCommand.verifyPrecondition()
protected void	CoordRerunXCommand.verifyPrecondition()
protected void	CoordPushDependencyCheckXCommand.verifyPrecondition()
protected void	CoordPauseXCommand.verifyPrecondition()
protected void	CoordMaterializeTransitionXCommand.verifyPrecondition()
protected void	CoordKillXCommand.verifyPrecondition()
protected void	CoordJobXCommand.verifyPrecondition()
protected void	CoordJobsXCommand.verifyPrecondition()
protected void	CoordChangeXCommand.verifyPrecondition()
protected void	CoordActionUpdateXCommand.verifyPrecondition()
protected void	CoordActionTimeOutXCommand.verifyPrecondition()
protected void	CoordActionReadyXCommand.verifyPrecondition()
protected void	CoordActionNotificationXCommand.verifyPrecondition()
protected void	CoordActionInputCheckXCommand.verifyPrecondition()
protected void	CoordActionInfoXCommand.verifyPrecondition()
protected void	CoordActionCheckXCommand.verifyPrecondition()

Constructors in org.apache.oozie.command.coord that throw CommandException

CoordChangeXCommand(String id, String changeValue)
This command is used to update the Coordinator job with the new values Update the coordinator job bean and update that to database.

Uses of CommandException in org.apache.oozie.command.wf

Methods in org.apache.oozie.command.wf that throw CommandException

protected void	SuspendXCommand.eagerLoadState()
protected void	ReRunXCommand.eagerLoadState() Loading the Wfjob and workflow actions.
protected void	CompletedActionXCommand.eagerLoadState()
protected void	ActionCheckXCommand.eagerLoadState()
protected void	SuspendXCommand.eagerVerifyPrecondition()
protected void	ReRunXCommand.eagerVerifyPrecondition() Checks the pre-conditions that are required for workflow to recover - Last run of Workflow should be completed - The nodes that are to be skipped are to be completed successfully in the base run.
protected void	CompletedActionXCommand.eagerVerifyPrecondition()
protected void	ActionCheckXCommand.eagerVerifyPrecondition()
protected WorkflowActionBean	WorkflowActionInfoXCommand.execute()
protected Void	WfEndXCommand.execute()
protected Void	SuspendXCommand.execute()
protected String	SubmitXCommand.execute()
protected String	SubmitHttpXCommand.execute()
protected Void	SignalXCommand.execute()
protected Void	ResumeXCommand.execute()
protected Void	ReRunXCommand.execute()
protected Void	NotificationXCommand.execute()
protected Void	KillXCommand.execute()
protected WorkflowJobBean	JobXCommand.execute()
protected WorkflowsInfo	JobsXCommand.execute()
protected String	ExternalIdXCommand.execute()
protected String	DefinitionXCommand.execute()
protected Void	CompletedActionXCommand.execute()
protected Void	ActionStartXCommand.execute()
protected Void	ActionKillXCommand.execute()
protected Void	ActionEndXCommand.execute()
protected Void	ActionCheckXCommand.execute()
void	ActionXCommand.failJob(ActionExecutor.Context context) Fail the job due to failed action
void	ActionXCommand.failJob(ActionExecutor.Context context, WorkflowActionBean action) Fail the job due to failed action
protected void	ActionXCommand.handleError(ActionExecutor.Context context, ActionExecutor executor, String message, boolean isStart, org.apache.oozie.client.WorkflowAction.Status status) Takes care of errors.
protected void	ActionXCommand.handleNonTransient(ActionExecutor.Context context, ActionExecutor executor, org.apache.oozie.client.WorkflowAction.Status status) Takes care of non transient failures.
protected boolean	ActionXCommand.handleTransient(ActionExecutor.Context context, ActionExecutor executor, org.apache.oozie.client.WorkflowAction.Status status) Takes care of Transient failures.
boolean	ActionXCommand.handleUserRetry(WorkflowActionBean action) Execute retry for action if this action is eligible for user-retry
protected void	WfEndXCommand.loadState()
protected void	SuspendXCommand.loadState()
protected void	SignalXCommand.loadState()
protected void	ResumeXCommand.loadState()
protected void	ReRunXCommand.loadState()
protected void	NotificationXCommand.loadState()
protected void	KillXCommand.loadState()
protected void	JobXCommand.loadState()
protected void	JobsXCommand.loadState()
protected void	ExternalIdXCommand.loadState()
protected void	DefinitionXCommand.loadState()
protected void	CompletedActionXCommand.loadState()
protected void	ActionStartXCommand.loadState()
protected void	ActionKillXCommand.loadState()
protected void	ActionEndXCommand.loadState()
protected void	ActionCheckXCommand.loadState()
static String	SubmitXCommand.resolveSla(org.jdom.Element eSla, ELEvaluator evalSla) Resolve variables in sla xml element.
static void	SuspendXCommand.suspendJob(JPAService jpaService, WorkflowJobBean workflow, String id, String actionId, List<JsonBean> updateList) Suspend the workflow job and pending flag to false for the actions that are START_RETRY or START_MANUAL or END_RETRY or END_MANUAL
protected void	WorkflowActionInfoXCommand.verifyPrecondition()
protected void	WfEndXCommand.verifyPrecondition()
protected void	SuspendXCommand.verifyPrecondition()
protected void	SubmitXCommand.verifyPrecondition()
protected void	SubmitScriptLanguageXCommand.verifyPrecondition()
protected void	SubmitMRXCommand.verifyPrecondition()
protected void	SignalXCommand.verifyPrecondition()
protected void	ResumeXCommand.verifyPrecondition()
protected void	ReRunXCommand.verifyPrecondition()
protected void	NotificationXCommand.verifyPrecondition()
protected void	KillXCommand.verifyPrecondition()
protected void	JobXCommand.verifyPrecondition()
protected void	JobsXCommand.verifyPrecondition()
protected void	ExternalIdXCommand.verifyPrecondition()
protected void	DefinitionXCommand.verifyPrecondition()
protected void	CompletedActionXCommand.verifyPrecondition()
protected void	ActionStartXCommand.verifyPrecondition()
protected void	ActionKillXCommand.verifyPrecondition()
protected void	ActionEndXCommand.verifyPrecondition()
protected void	ActionCheckXCommand.verifyPrecondition()

Uses of CommandException in org.apache.oozie.coord

Methods in org.apache.oozie.coord that throw CommandException

static List<CoordinatorActionBean>	CoordUtils.getCoordActionsFromDates(String jobId, String scope) Get the list of actions for given date ranges
static List<CoordinatorActionBean>	CoordUtils.getCoordActionsFromIds(String jobId, String scope) Get the list of actions for given id ranges

Uses of CommandException in org.apache.oozie.dependency

Methods in org.apache.oozie.dependency that throw CommandException

static ActionDependency	DependencyChecker.checkForAvailability(String[] missingDependencies, org.apache.hadoop.conf.Configuration actionConf, boolean stopOnFirstMissing) Get the currently missing and available dependencies after checking the list of known missing dependencies against the source.
static ActionDependency	DependencyChecker.checkForAvailability(String missingDependencies, org.apache.hadoop.conf.Configuration actionConf, boolean stopOnFirstMissing) Get the currently missing and available dependencies after checking the list of known missing dependencies against the source.

Uses of CommandException in org.apache.oozie.sla

Methods in org.apache.oozie.sla that throw CommandException

static SLARegistrationBean	SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla, String jobId, org.apache.oozie.AppType appType, String user, String appName, XLog log)
static SLARegistrationBean	SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla, String jobId, org.apache.oozie.AppType appType, String user, XLog log)
static SLARegistrationBean	SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla, String jobId, String parentId, org.apache.oozie.AppType appType, String user, String appName, XLog log, boolean rerun)
static SLARegistrationBean	SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla, String jobId, String parentId, org.apache.oozie.AppType appType, String user, XLog log)
static void	SLAOperations.updateRegistrationEvent(String jobId) Retrieve registration event

Uses of CommandException in org.apache.oozie.util

Methods in org.apache.oozie.util that throw CommandException

static void	PropertiesUtils.checkDisallowedProperties(org.apache.hadoop.conf.Configuration conf, Set<String> set) Validate against DISALLOWED Properties.
static Map<String,String>	JobUtils.parseChangeValue(String changeValue) This Function will parse the value of the changed values in key value manner.

Uses of CommandException in org.apache.oozie.util.db

Methods in org.apache.oozie.util.db that throw CommandException

static SLAEventBean	SLADbXOperations.createStatusEvent(String slaXml, String id, org.apache.oozie.client.SLAEvent.Status stat, org.apache.oozie.client.SLAEvent.SlaAppType appType) Deprecated. Create SLA status event
static SLAEventBean	SLADbOperations.createStatusEvent(String slaXml, String id, org.apache.oozie.client.SLAEvent.Status stat, org.apache.oozie.client.SLAEvent.SlaAppType appType, XLog log) Deprecated.