Hi, The relevant code snippet posted here http://pastebin.com/DRPXUm62
On Tue, Jan 15, 2013 at 5:31 PM, jamal sasha <[email protected]> wrote: > My bad. Sorry I fixed it. It is BuildGraph.class > > > On Tue, Jan 15, 2013 at 5:30 PM, Serge Blazhiyevskyy < > [email protected]> wrote: > >> Don't you need to set this >> >> conf.setMapperClass(Mapper.class); >> >> to BuildGraph? >> >> >> Serge >> >> >> SERGE BLAZHIYEVSKY >> Architect >> (T) +1 (650) 226-0511 >> (M) +1 (408) 772-2615 >> [email protected]<mailto:[email protected]> >> www.nice.com<http://www.nice.com> >> >> >> On Jan 15, 2013, at 5:24 PM, jamal sasha <[email protected]<mailto: >> [email protected]>> wrote: >> >> I have a mapper >> >> >> public class BuildGraph{ >> public void config(JobConf job){ <==this block doesnt seems to be >> exexcuting at all :( >> super.configure(job); >> this.currentId = job.getInt("currentId",0); >> if (this.currentId!=0){ >> // I call a method from differnt class to build a distributed >> cache >> } >> } >> public void map(....){ >> .... >> } >> } >> >> now the main code where this is called.. >> >> public void run( String params,curId){ >> JobConf conf = new JobConf(classname.class); >> conf.setInt("currentId",299); <--note this i am setting the value >> here >> conf.setMapperClass(Mapper.class); >> //.... >> JobClient.runJob(conf); >> } >> >> But the problem is config method in the code is not executing as though >> "currentId" returns 299 in main loop but it is not set at all in the mapper >> class. >> what am i doing wrong >> >> >
