Hi Raakhi,

JobControl is designed to be run from a new thread:

Thread t = new Thread(jobControl);
t.start();

Then you can run a loop to poll for job completion and print out status:

    String oldStatus = null;
    while (!jobControl.allFinished()) {
      String status = getStatusString(jobControl);
      if (!status.equals(oldStatus)) {
        System.out.println(status);
        oldStatus = status;
      }
      try {
        Thread.sleep(1000);
      } catch (InterruptedException e) {
        // ignore
      }
    }

Hope this helps.

Tom

On Fri, Jul 17, 2009 at 9:10 AM, Rakhi Khatwani<rakhi.khatw...@gmail.com> wrote:
> Hi,
>       I was trying out a map-reduce example using JobControl.
> i create a jobConf conf1 object, add the necessary information
> then i create a job object
> Job job1 = new Job(conf1);
>
> n thn i delare JobControl object as follows:
> JobControl jobControl = new JobControl("JobControl1");
>                  jobControl.addJob(job1);
>                  jobControl.run();
>
>
>
> whn i execute it in the console,
> i get the following output
> 09/07/17 13:10:16 WARN mapred.JobClient: Use GenericOptionsParser for
> parsing the arguments. Applications should implement Tool for the same.
> 09/07/17 13:10:16 INFO mapred.FileInputFormat: Total input paths to process
> : 4
>
>
>
>
> n there is no other output.
> but from the UI i can c that the job has been executed.
> if there any way i can direct the output to the console.
> or is there any way in which while the job is runing, i can continue
> processing from main. (i wanna try suspending/stopping jobs etc).
>
> Regards,
> Raakhi
>

Reply via email to