Examples of eu.stratosphere.nephele.client.JobClient.submitJobAndWait()

Class eu.stratosphere.nephele.client.JobClient

Examples of eu.stratosphere.nephele.client.JobClient.submitJobAndWait()

eu.stratosphere.nephele.client.JobClient.submitJobAndWait()
Submits the job assigned to this job client to the job manager and queries the job manager about the progress of the job until it is either finished or aborted. @return the duration of the job execution in milliseconds @throws IOException thrown if an error occurred while transmitting the request @throws JobExecutionException thrown if the job has been aborted either by the user or as a result of an error

      Logger rtLogger = Logger.getLogger(Task.class);
      Level rtLevel = rtLogger.getEffectiveLevel();
      rtLogger.setLevel(Level.OFF);
      
      try {
        jobClient.submitJobAndWait();
      } catch (JobExecutionException e) {
        // Check if the correct error message is encapsulated in the exception
        if (e.getMessage() == null) {
          fail("JobExecutionException does not contain an error message");
        }

View Full Code Here

    public void run() {
      try {
        // submit failing job
        JobClient client = this.executor.getJobClient(this.failingJob);
        client.setConsoleStreamForReporting(AbstractTestBase.getNullPrintStream());
        client.submitJobAndWait();
        
        this.error = new Exception("The job did not fail.");
      } catch(JobExecutionException jee) {
        // as expected
      } catch (Exception e) {

View Full Code Here

      
      try {
        // submit working job
        JobClient client = this.executor.getJobClient(this.job);
        client.setConsoleStreamForReporting(AbstractTestBase.getNullPrintStream());
        client.submitJobAndWait();
      } catch (Exception e) {
        this.error = e;
      }
      
      // interrupt timeout thread

View Full Code Here

    
    client.setConsoleStreamForReporting(this.printStatusDuringExecution ? System.out : null);


    try {
      if (wait) {
        return client.submitJobAndWait();
      }
      else {
        JobSubmissionResult result = client.submitJob();
        
        if (result.getReturnCode() != ReturnCode.SUCCESS) {

View Full Code Here

        
        NepheleJobGraphGenerator jgg = new NepheleJobGraphGenerator();
        JobGraph jobGraph = jgg.compileJobGraph(op);
        
        JobClient jobClient = this.nephele.getJobClient(jobGraph);
        JobExecutionResult result = jobClient.submitJobAndWait();
        return result;
      }
      finally {
        if (shutDownAtEnd) {
          stop();

View Full Code Here

0 1

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.