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()

        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

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

    Assert.assertNotNull("Obtained null JobGraph", jobGraph);
    
    try {
      JobClient client = this.executor.getJobClient(jobGraph);
      client.setConsoleStreamForReporting(getNullPrintStream());
      this.jobExecutionResult = client.submitJobAndWait();
    }
    catch(Exception e) {
      System.err.println(e.getMessage());
      e.printStackTrace();
      Assert.fail("Job execution failed!");

View Full Code Here

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

  private JobGraphUtils() {
  }


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

View Full Code Here

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

      // deactivate logging of expected test exceptions
      Logger jcLogger = Logger.getLogger(JobClient.class);
      Level jcLevel = jcLogger.getEffectiveLevel();
      jcLogger.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()


      // Create job client and launch job
      jobClient = new JobClient(jg, configuration);
      
      try {
        jobClient.submitJobAndWait();
      } catch (JobExecutionException e) {
        fail(e.getMessage());
      }


      // Finally, compare output file to initial number sequence

View Full Code Here

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

      // add jar
      jg.addJar(new Path(jarFile.toURI()));


      // Create job client and launch job
      jobClient = new JobClient(jg, configuration);
      jobClient.submitJobAndWait();


    } catch (JobExecutionException e) {
      fail(e.getMessage());
    } catch (JobGraphDefinitionException jgde) {
      fail(jgde.getMessage());

View Full Code Here

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

      // add jar
      jg.addJar(new Path(jarFile.toURI()));


      // Create job client and launch job
      jobClient = new JobClient(jg, configuration);
      jobClient.submitJobAndWait();


    } catch (JobExecutionException e) {
      fail(e.getMessage());
    } catch (JobGraphDefinitionException jgde) {
      fail(jgde.getMessage());

View Full Code Here

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


      // Create job client and launch job
      jobClient = new JobClient(jg, configuration);


      try {
        jobClient.submitJobAndWait();
      } catch (JobExecutionException e) {
        fail(e.getMessage());
      }


      // Finally, check the output

View Full Code Here

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

      
      tmLogger.setLevel(Level.OFF);
      jcLogger.setLevel(Level.OFF);
      try {
        
        jobClient.submitJobAndWait();
      } catch (JobExecutionException e) {
        // Job execution should lead to an error due to lack of resources
        return;
      }
      finally {

View Full Code Here

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

      // add jar
      jg.addJar(new Path(new File(ServerTestUtils.getTempDir() + File.separator + forwardClassName + ".jar").toURI()));


      // Create job client and launch job
      jobClient = new JobClient(jg, configuration);
      jobClient.submitJobAndWait();


      // Finally, compare output file to initial number sequence
      final BufferedReader bufferedReader = new BufferedReader(new FileReader(outputFile));
      for (int i = 0; i < sizeOfInput; i++) {
        final String number = bufferedReader.readLine();

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.