Package org.apache.oozie.command

Examples of org.apache.oozie.command.CommandException

85
86
87
88
89
90
91
92
93
94
95
96
                this.wfAction = jpaService.execute(new WorkflowActionGetJPAExecutor(actionId));
                LogUtils.setLogInfo(wfJob, logInfo);
                LogUtils.setLogInfo(wfAction, logInfo);
            }
            else {
                throw new CommandException(ErrorCode.E0610);
            }
        }
        catch (XException ex) {
            throw new CommandException(ex);
        }
    }
View Full Code Here
115
116
117
118
119
120
121
122
            throw new PreconditionException(ErrorCode.E0812, wfAction.getPending(), wfAction.getStatusStr());
        }

        executor = Services.get().get(ActionService.class).getExecutor(wfAction.getType());
        if (executor == null) {
            throw new CommandException(ErrorCode.E0802, wfAction.getType());
        }
    }
View Full Code Here
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
            try {
                jpaService.execute(new WorkflowActionUpdateJPAExecutor(wfAction));
                jpaService.execute(new WorkflowJobUpdateJPAExecutor(wfJob));
            }
            catch (JPAExecutorException je) {
                throw new CommandException(je);
            }

        }
        catch (JPAExecutorException je) {
            throw new CommandException(je);
        }


        LOG.debug("ENDED ActionEndXCommand for action " + actionId);
        return null;
View Full Code Here
54
55
56
57
58
59
60
61
62
63
64
                try {
                    jpaService.execute(new WorkflowJobDeleteJPAExecutor(wfId));
                    actionDeleted += jpaService.execute(new WorkflowActionsDeleteForPurgeJPAExecutor(wfId));
                }
                catch (JPAExecutorException e) {
                    throw new CommandException(e);
                }
            }
            LOG.debug("ENDED Workflow-Purge deleted jobs :" + jobList.size() + " and actions " + actionDeleted);
        }
        else {
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
95
96
            if (jpaService != null) {
                this.jobList = jpaService.execute(new WorkflowJobsGetForPurgeJPAExecutor(olderThan, limit));
            }
            else {
                throw new CommandException(ErrorCode.E0610);
            }
        }
        catch (XException ex) {
            throw new CommandException(ex);
        }

    }
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
93
                this.wfAction = jpaService.execute(new WorkflowActionGetJPAExecutor(actionId));
                LogUtils.setLogInfo(wfJob, logInfo);
                LogUtils.setLogInfo(wfAction, logInfo);
            }
            else {
                throw new CommandException(ErrorCode.E0610);
            }
        }
        catch (XException ex) {
            throw new CommandException(ex);
        }
    }
View Full Code Here
109
110
111
112
113
114
115
116
            }
        }

        executor = Services.get().get(ActionService.class).getExecutor(wfAction.getType());
        if (executor == null) {
            throw new CommandException(ErrorCode.E0802, wfAction.getType());
        }
    }
View Full Code Here
138
139
140
141
142
143
144
145
146
147
            wfAction.setLastCheckTime(new Date());
            try {
                jpaService.execute(new WorkflowActionUpdateJPAExecutor(wfAction));
            }
            catch (JPAExecutorException e) {
                throw new CommandException(e);
            }
            throw new PreconditionException(ErrorCode.E0818, wfAction.getId(), wfJob.getId(), wfJob.getStatus());
        }
    }
View Full Code Here
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
            try {
                jpaService.execute(new WorkflowActionUpdateJPAExecutor(wfAction));
                jpaService.execute(new WorkflowJobUpdateJPAExecutor(wfJob));
            }
            catch (JPAExecutorException e) {
                throw new CommandException(e);
            }
            return null;
        }
        catch (JPAExecutorException e) {
            throw new CommandException(e);
        }

        LOG.debug("ENDED ActionCheckXCommand for wf actionId=" + actionId + ", jobId=" + jobId);
        return null;
    }
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
            CoordinatorActionBean action = em.find(CoordinatorActionBean.class, coordActionId);
            if (action != null) {
                em.remove(action);
            }
            else {
                throw new CommandException(ErrorCode.E0605, coordActionId);
            }

            return null;
        }
        catch (Exception e) {
View Full Code Here
TOP

Related Classes of org.apache.oozie.command.CommandException

  • org.apache.oozie.command.BulkJobsXCommand
  • org.apache.oozie.command.bundle.BundleJobChangeXCommand
  • org.apache.oozie.command.bundle.BundleJobResumeXCommand
  • org.apache.oozie.command.bundle.BundleJobSuspendXCommand
  • org.apache.oozie.command.bundle.BundleJobsXCommand
  • org.apache.oozie.command.bundle.BundleJobXCommand
  • org.apache.oozie.command.bundle.BundleKillXCommand
  • org.apache.oozie.command.bundle.BundlePauseXCommand
  • org.apache.oozie.command.bundle.BundlePurgeXCommand
  • org.apache.oozie.command.bundle.BundleRerunXCommand
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.