List of submitJobAndWait() Examples

Examples of 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
org.apache.flink.runtime.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

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

      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

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

    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

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

      
      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

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

    
    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

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

        
        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

Examples of org.apache.flink.runtime.client.JobClient.submitJobAndWait()

    
    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

Examples of org.apache.flink.runtime.client.JobClient.submitJobAndWait()

  private JobGraphUtils() {}
  


  public static void submit(JobGraph graph, Configuration nepheleConfig) throws IOException, JobExecutionException {
    JobClient client = new JobClient(graph, nepheleConfig, JobGraphUtils.class.getClassLoader());
    client.submitJobAndWait();
  }
  
  public static <T extends FileInputFormat<?>> InputFormatVertex createInput(T stub, String path, String name, JobGraph graph,
      int degreeOfParallelism)
  {

View Full Code Here

Examples of org.apache.flink.runtime.client.JobClient.submitJobAndWait()

    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

Examples of org.apache.flink.runtime.client.JobClient.submitJobAndWait()

      
      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

Examples of org.apache.flink.runtime.client.JobClient.submitJobAndWait()

        NepheleJobGraphGenerator jgg = new NepheleJobGraphGenerator();
        JobGraph jobGraph = jgg.compileJobGraph(op);


        JobClient client = this.executor.getJobClient(jobGraph);
        client.setConsoleStreamForReporting(AbstractTestBase.getNullPrintStream());
        JobExecutionResult result = client.submitJobAndWait();
        
        this.latestResult = result;
        return result;
      }
      catch (Exception e) {

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.