大佬們，本人剛剛接觸hadoop就遇到這個，這個問題我太頭疼了，大佬們請幫我一下?。。?/p>

/創(chuàng)建靜態(tài)內(nèi)部類MyMapper

public static class MyMapper extends Mapper<LongWritable,Text,Text,LongWritable>{

//調(diào)用自帶的map（）函數(shù)

protected void map(LongWritable k1,Text v1,Context context)?

throws IOException,InterruptedException{

//k1代表的是每一行的偏移量，v1代表的是每一行的內(nèi)容

//將傳送進來的每一行數(shù)據(jù)切割，切割成單詞

String[] words =v1.toString().split(" ");

//迭代切割出來的單詞數(shù)據(jù)

for(String word:words) {

//將迭代出來的單詞數(shù)據(jù)封裝成<k2,v2>

Text k2 =new Text(word);

LongWritable v2=new LongWritable();

? ? ?//把<k2,v2>寫出去

context.write(k2, v2);

}

}

}

//創(chuàng)建自定義靜態(tài)內(nèi)部類MyReducer

public static class MyReducer extends Reducer<Text,LongWritable,Text,LongWritable>{

/*

* 針對v2s做累加求和，并且最終把<k3,v3>寫出去

*/

protected void reducer(Text k2,Iterable<LongWritable> v2s,Context context)

? ? ? throws IOException,InterruptedException{

//創(chuàng)建一個表量sum來保存v2s的累加值

long sum=0;

for(LongWritable v2:v2s) {

sum=sum+v2.get();

}

//組裝<k3,v3>

Text k3=k2;

LongWritable v3=new LongWritable(sum);

//把組裝好的<k3,v3>寫出去

context.write(k3, v3);

}

}

代碼好像沒什么問題？

我猜你的map的初始值是0吧？而且reduce沒有求和，檢查一下你的代碼？