Examples of CoordSubmitXCommand

org.apache.oozie.command.coord.CoordSubmitXCommand
This class provides the functionalities to resolve a coordinator job XML and write the job information into a DB table.
Specifically it performs the following functions: 1. Resolve all the variables or properties using job configurations. 2. Insert all datasets definition as part of the and tags. 3. Validate the XML at runtime.

Examples of org.apache.oozie.command.coord.CoordSubmitXCommand

                for (Element coordElem : coordElems) {
                    Attribute name = coordElem.getAttribute("name");
                    Configuration coordConf = mergeConfig(coordElem);
                    coordConf.set(OozieClient.BUNDLE_ID, jobId);


                    queue(new CoordSubmitXCommand(coordConf, bundleJob.getAuthToken(), bundleJob.getId(), name.getValue()));


                }
                updateBundleAction();
            }
            catch (JDOMException jex) {

View Full Code Here

Examples of org.apache.oozie.command.coord.CoordSubmitXCommand

     * , boolean)
     */
    @Override
    public String submitJob(Configuration conf, boolean startJob) throws CoordinatorEngineException {
        try {
      CoordSubmitXCommand submit = new CoordSubmitXCommand(conf,
          getAuthToken());
      return submit.call();
        }
        catch (CommandException ex) {
            throw new CoordinatorEngineException(ex);
        }
    }

View Full Code Here

Examples of org.apache.oozie.command.coord.CoordSubmitXCommand

     * , boolean)
     */
    @Override
    public String dryrunSubmit(Configuration conf, boolean startJob) throws CoordinatorEngineException {
        try {
      CoordSubmitXCommand submit = new CoordSubmitXCommand(true, conf,
          getAuthToken());
      return submit.call();
        }
        catch (CommandException ex) {
            throw new CoordinatorEngineException(ex);
        }
    }

View Full Code Here

Examples of org.apache.oozie.command.coord.CoordSubmitXCommand

     * , boolean)
     */
    @Override
    public String submitJob(Configuration conf, boolean startJob) throws CoordinatorEngineException {
        try {
            CoordSubmitXCommand submit = new CoordSubmitXCommand(conf);
            return submit.call();
        }
        catch (CommandException ex) {
            throw new CoordinatorEngineException(ex);
        }
    }

View Full Code Here

Examples of org.apache.oozie.command.coord.CoordSubmitXCommand

     * org.apache.oozie.BaseEngine#dryRunSubmit(org.apache.hadoop.conf.Configuration)
     */
    @Override
    public String dryRunSubmit(Configuration conf) throws CoordinatorEngineException {
        try {
            CoordSubmitXCommand submit = new CoordSubmitXCommand(true, conf);
            return submit.call();
        }
        catch (CommandException ex) {
            throw new CoordinatorEngineException(ex);
        }
    }

View Full Code Here

Examples of org.apache.oozie.command.coord.CoordSubmitXCommand

                                    log.error("Error evaluating coord name " + e.getMessage(), e);
                                    continue;
                                }
                                if (coordName.equals(baction.getCoordName())) {
                                    coordConf.set(OozieClient.BUNDLE_ID, baction.getBundleId());
                                    queueCallable(new CoordSubmitXCommand(coordConf,
                                            bundleJob.getId(), coordName));
                                }
                            }
                        }
                        else if (baction.getStatus() == Job.Status.KILLED) {

View Full Code Here

Examples of org.apache.oozie.command.coord.CoordSubmitXCommand

        String expectedEnd = DateUtils.formatDateOozieTZ(cal.getTime());
        String appName = "test-coord-sla";


        // testing creation of new sla registration via Submit + Materialize
        // command
        String jobId = new CoordSubmitXCommand(conf).call();
        Thread.sleep(500); // waiting for materialize command to run
        final CoordActionGetJPAExecutor getCmd = new CoordActionGetJPAExecutor(jobId + "@1");
        CoordinatorActionBean action = jpa.execute(getCmd);
        String actionId = action.getId();
        SLACalcStatus slaEvent = slas.getSLACalculator().get(actionId);

View Full Code Here

Examples of org.apache.oozie.command.coord.CoordSubmitXCommand

                    }
                    catch (Exception e) {
                        throw new CommandException(ErrorCode.E1321, e.getMessage(), e);


                    }
                    queue(new CoordSubmitXCommand(coordConf, bundleJob.getId(), name.getValue()));


                }
                updateBundleAction();
            }
            catch (JDOMException jex) {

View Full Code Here

Examples of org.apache.oozie.command.coord.CoordSubmitXCommand

     * , boolean)
     */
    @Override
    public String submitJob(Configuration conf, boolean startJob) throws CoordinatorEngineException {
        try {
            CoordSubmitXCommand submit = new CoordSubmitXCommand(conf);
            return submit.call();
        }
        catch (CommandException ex) {
            throw new CoordinatorEngineException(ex);
        }
    }

View Full Code Here

Examples of org.apache.oozie.command.coord.CoordSubmitXCommand

     * org.apache.oozie.BaseEngine#dryRunSubmit(org.apache.hadoop.conf.Configuration)
     */
    @Override
    public String dryRunSubmit(Configuration conf) throws CoordinatorEngineException {
        try {
            CoordSubmitXCommand submit = new CoordSubmitXCommand(true, conf);
            return submit.call();
        }
        catch (CommandException ex) {
            throw new CoordinatorEngineException(ex);
        }
    }

View Full Code Here

0 1 2

TOP

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.