List of submitJob() Examples

Examples of submitJob()

appeng.api.networking.crafting.ICraftingGrid.submitJob()
appeng.me.cluster.implementations.CraftingCPUCluster.submitJob()
au.org.aodn.reefscenarios.actions.job.ProcessRunner.submitJob()
ca.eandb.jdcp.remote.JobService.submitJob()
Submits a job previously created using {@link #createJob(String)}. @param job The ParallelizableJob being submitted. It mustbe wrapped in a Serialized wrapper to bypass RMI deserialization. @param jobId The UUID associated with the previouslycreated job. @throws IllegalArgumentException If jobId does notcorrespond to a job on the server that is awaiting submission. @throws SecurityException If the caller does not have permission tosubmit jobs. @throws ClassNotFoundException If deserialization of jobrequires a class which does not exist on the server. @throws RemoteException If a communication error occurs. @throws JobExecutionException If the submitted job throws an exceptionwhile being initialized.
com.netflix.genie.client.ExecutionServiceClient.submitJob()
Submits a job using given parameters. @param job for submitting job (can't be null)
More details can be found on the Genie User Guide on GitHub. @return updated jobInfo for submitted job, if there is no error @throws GenieException For any other error.
edu.berkeley.sparrow.api.SparrowFrontendClient.submitJob()
edu.berkeley.sparrow.thrift.SchedulerService.Client.submitJob()
eu.stratosphere.nephele.client.JobClient.submitJob()
Submits the job assigned to this job client to the job manager. @return a JobSubmissionResult object encapsulating the results of the job submission @throws IOException thrown in case of submission errors while transmitting the data to the job manager
gri.tasks.managers.JobManager.submitJob()
Submits the given job, invoking the task and returning a Job ID which will be used to identify this job.
org.apache.airavata.gfac.GFacAPI.submitJob()
org.apache.airavata.gfac.core.cpi.GFac.submitJob()
This is the job launching method outsiders of GFac can use, this will invoke the GFac handler chain and providers And update the registry occordingly, so the users can query the database to retrieve status and output from Registry @param experimentID @return boolean Successful acceptence of the jobExecution returns a true value @throws org.apache.airavata.gfac.GFacException
org.apache.airavata.gfac.core.cpi.GFacImpl.submitJob()
This is the job launching method outsiders of GFac can use, this will invoke the GFac handler chain and providers And update the registry occordingly, so the users can query the database to retrieve status and output from Registry @param experimentID @return @throws GFacException
org.apache.airavata.gfac.cpi.GFacImpl.submitJob()
org.apache.flink.runtime.client.JobClient.submitJob()
Submits the job assigned to this job client to the job manager. @return a JobSubmissionResult object encapsulating the results of the job submission @throws IOException thrown in case of submission errors while transmitting the data to the job manager
org.apache.hadoop.mapred.JobClient.submitJob()
Submit a job to the MR system. This returns a handle to the {@link RunningJob} which can be used to trackthe running-job. @param jobFile the job configuration. @return a handle to the {@link RunningJob} which can be used to track therunning-job. @throws FileNotFoundException @throws InvalidJobConfException @throws IOException
org.apache.hadoop.mapreduce.protocol.ClientProtocol.submitJob()
Submit a Job for execution. Returns the latest profile for that job.
org.apache.hama.bsp.BSPJobClient.submitJob()
Submit a job to the BSP system. This returns a handle to the {@link RunningJob} which can be used to track the running-job. @param job the job configuration. @return a handle to the {@link RunningJob} which can be used to track therunning-job. @throws FileNotFoundException @throws IOException
org.apache.oodt.cas.resource.system.XmlRpcResourceManagerClient.submitJob()
org.apache.oozie.BundleEngine.submitJob()
org.apache.oozie.CoordinatorEngine.submitJob()
org.apache.oozie.DagEngine.submitJob()
Submit a workflow job.
It validates configuration properties. @param conf job configuration. @param startJob indicates if the job should be started or not. @return the job Id. @throws DagEngineException thrown if the job could not be created.

Examples of org.apache.hadoop.mapred.JobClient.submitJob()

      jobConf.setInt("mapred.map.max.attempts", 1);
      jobConf.setInt("mapred.reduce.max.attempts", 1);
      jobConf.set("mapred.input.dir", inputDir.toString());
      jobConf.set("mapred.output.dir", outputDir.toString());
      JobClient jobClient = new JobClient(jobConf);
      RunningJob runJob = jobClient.submitJob(jobConf);
      runJob.waitForCompletion();
      Assert.assertTrue(runJob.isComplete());
      Assert.assertTrue(runJob.isSuccessful());
    } finally {
      stopCluster();

View Full Code Here

Examples of org.apache.hadoop.mapred.JobClient.submitJob()

    FileOutputStream fos = new FileOutputStream(inFile.toString());
    fos.write((line1 + "\n").getBytes());
    fos.write((line2 + "\n").getBytes());
    fos.close();
    JobClient jc = new JobClient(conf);
    RunningJob r_job = jc.submitJob(conf);
    while (!r_job.isComplete()) {
      Thread.sleep(1000);
    }
    
    if (!r_job.isSuccessful()) {

View Full Code Here

Examples of org.apache.hadoop.mapred.JobClient.submitJob()




      // make this client wait if job trcker is not behaving well.
      Throttle.checkJobTracker(job, LOG);


      orig_rj = rj = jc.submitJob(job);
      // replace it back
      if (pwd != null)
        job.set(HiveConf.ConfVars.METASTOREPWD.varname, pwd);


      // add to list of running jobs so in case of abnormal shutdown can kill

View Full Code Here

Examples of org.apache.hadoop.mapreduce.protocol.ClientProtocol.submitJob()

      }
    });
    Path qJobSubmitDir = jobSubmitDir.makeQualified(fs);
    uploadJobFiles(JobID.downgrade(id), splits, qJobSubmitDir, ugi, job);
    
    jobSubmitClient.submitJob(id, qJobSubmitDir.toString(), null);
    
    JobClient jc = new JobClient(job);
    return jc.getJob(JobID.downgrade(id));
  }

View Full Code Here

Examples of org.apache.hama.bsp.BSPJobClient.submitJob()

    bsp.setNumBspTask(cluster.getMaxTasks());


    LOG.info("Client conf: "
        + clientConf.get("hadoop.rpc.socket.factory.class.default"));


    RunningJob rJob = jobClient.submitJob(bsp);
    rJob.waitForCompletion();
    LOG.info("finished");
  }


}

View Full Code Here

Examples of org.apache.oodt.cas.resource.system.XmlRpcResourceManagerClient.submitJob()

          "org.apache.oodt.cas.resource.structs.NameValueJobInput", "quick",
          new Integer(1));
      NameValueJobInput hw1Input = new NameValueJobInput();
      hw1Input.setNameValuePair("user.name", "Dave");


      client.submitJob(hw1, hw1Input);


    } catch (Exception e) {
      e.printStackTrace();
    }

View Full Code Here

Examples of org.apache.oozie.BundleEngine.submitJob()

            }
            if (dryrun) {
                id = bundleEngine.dryrunSubmit(conf, startJob);
            }
            else {
                id = bundleEngine.submitJob(conf, startJob);
            }
            json.put(JsonTags.JOB_ID, id);
        }
        catch (BundleEngineException ex) {
            throw new XServletException(HttpServletResponse.SC_BAD_REQUEST, ex);

View Full Code Here

Examples of org.apache.oozie.CoordinatorEngine.submitJob()

            }
            if (dryrun) {
                id = coordEngine.dryrunSubmit(conf, startJob);
            }
            else {
                id = coordEngine.submitJob(conf, startJob);
            }
            json.put(JsonTags.JOB_ID, id);
        }
        catch (CoordinatorEngineException ex) {
            throw new XServletException(HttpServletResponse.SC_BAD_REQUEST, ex);

View Full Code Here

Examples of org.apache.oozie.DagEngine.submitJob()

        jobConf.set(OozieClient.LOG_TOKEN, "t");


        jobConf.set("external-status", "ok");
        jobConf.set("signal-value", "based_on_action_status");


        final String jobId = engine.submitJob(jobConf, true);


        HadoopAccessorService has = Services.get().get(HadoopAccessorService.class);
        URI uri = getFileSystem().getUri();
        Configuration fsConf = has.createJobConf(uri.getAuthority());
        FileSystem fileSystem = has.createFileSystem(getTestUser(), uri, fsConf);

View Full Code Here

Examples of org.apache.oozie.DagEngine.submitJob()

                SLADbOperations.writeStausEvent(coordAction.getSlaXml(), coordAction.getId(), Status.STARTED,
                                                SlaAppType.COORDINATOR_ACTION, log);


                // Normalize workflow appPath here;
                JobUtils.normalizeAppPath(conf.get(OozieClient.USER_NAME), conf.get(OozieClient.GROUP_NAME), conf);
                String wfId = dagEngine.submitJob(conf, startJob);
                coordAction.setStatus(CoordinatorAction.Status.RUNNING);
                coordAction.setExternalId(wfId);
                coordAction.incrementAndGetPending();


                //store.updateCoordinatorAction(coordAction);

View Full Code Here

0 1 2 3 4 5 6

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.