這幾天寫了WordCount.java京办。里面有段驅(qū)動(dòng)代碼:
Configuration conf = new Configuration();
Job job = Job.getInstance(conf, WordCountApp.class.getSimpleName());// 要執(zhí)行任務(wù)得創(chuàng)建一個(gè)job對(duì)象
job.setJarByClass(WordCountApp.class);// 打成jar包,這行代碼是必須的
FileInputFormat.setInputPaths(job, args[0]);// 設(shè)置輸入路徑
job.setMapperClass(MyMapper.class);// 把MyMapper告訴job
job.setMapOutputKeyClass(Text.class);// 設(shè)置map輸出的key的類型
job.setMapOutputValueClass(LongWritable.class);// 設(shè)置map輸出的value的類型
job.setReducerClass(MyReducer.class);// 把MyReducer告訴job
job.setOutputKeyClass(Text.class);// 設(shè)置輸出的key的類型
job.setOutputValueClass(LongWritable.class);// 設(shè)置輸出的value的類型
FileOutputFormat.setOutputPath(job, new Path(args[1]));// 設(shè)置輸出路徑
job.waitForCompletion(true);// 把任務(wù)提交到集群去執(zhí)行
我一看,咦岩遗!這個(gè)Job挺面生啊。就ctrl點(diǎn)進(jìn)去看看凤瘦。
結(jié)果悲劇了><
出現(xiàn)了source not found
根據(jù)以往的經(jīng)驗(yàn)宿礁,這時(shí)候要引入包了。
嘗試1:
把hadoop-2.6.0.tar.gz解壓后廷粒,又壓縮成hadoop-2.6.0.zip窘拯。點(diǎn)那個(gè)attch resource的按鈕->選擇external location->external file->選擇hadoop-2.6.0.zip->OK
結(jié)果并沒有什么卵用
嘗試2:
看到網(wǎng)上有人說源碼包如何如何红且。一拍腦門坝茎,源碼包里不是要啥有啥!說干就干暇番!
找到apache官網(wǎng)下載hadoop-2.6.0-src.tar.gz
鏈接:http://mirror.bit.edu.cn/apache/hadoop/common/hadoop-2.6.0/
把hadoop-2.6.0-src.tar.gz解壓后嗤放,又壓縮成hadoop-2.6.0-src.zip。點(diǎn)那個(gè)attch resource的按鈕->選擇external location->external file->選擇hadoop-2.6.0-src.zip->OK
居然成功了壁酬,也是醉了
bingo