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

/創建靜態內部類MyMapper

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

//調用自帶的map（）函數

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

throws IOException,InterruptedException{

//k1代表的是每一行的偏移量，v1代表的是每一行的內容

//將傳送進來的每一行數據切割，切割成單詞

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

//迭代切割出來的單詞數據

for(String word:words) {

//將迭代出來的單詞數據封裝成<k2,v2>

Text k2 =new Text(word);

LongWritable v2=new LongWritable();

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

context.write(k2, v2);

}

}

}

//創建自定義靜態內部類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{

//創建一個表量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沒有求和，檢查一下你的代碼？