|
job.waitForCompletion(ture)，这个方法属于job类—>它里面有一个submit()方法—>submit方法里面又有一个connect()方法,它的作用是连接到jobtracker—>在connect()方法中，创建了一个jobClient类的对象时，调用jobClient构造方法时，读取配置文件中的mapred-sie.xml中name为“mapred.job.tracker”,及创建那台服务器的客户端的代理对象，这个对象是JobSubmissionProtocol,而JobSubmissionProtocol的实现类就是JobTrack;之后在jobclient.submitJobInternal（）方法中，就调用了JobSubmissionProtocol的submitjob（）方法，也就是jobTracker调用了submitjob（）方法 | 
转播
