hadoop-mapreduce-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joan <joan.monp...@gmail.com>
Subject Chain multiple jobs
Date Thu, 10 Feb 2011 19:33:51 GMT
Hi,

I've two jobs and I'm trying to control them by ControlledJob.

job2 depends on job1 and the job2's input is the job1's output so when i do
this:

          cjob1 = new ControlledJob(job1, null);

          dependingJobs = new ArrayList<ControlledJob>();
          dependingJobs.add(cjob1);

          cjob2 = new ControlledJob(job2, dependingJobs);

          JobControl theControl = new JobControl("name");

          theControl.addJob(cjob1);
          theControl.addJob(cjob2);

          Thread theController = new Thread(theControl);
          theController.start();



I get the exception:

Exception in thread "main" java.io.FileNotFoundException: File "output from
job1" does not exist.

Because when "cjob2 = new ControlledJob(job2, dependingJobs);" is being
instanced the input of job2 doesn't exist.

Can someone help me?

Thanks

Joan

Mime
View raw message