java.lang.Exception: java.lang.ClassCastException: org.apache.hadoop.io.Text 无法转换为 org.apache.hadoop.io.IntWritable

【问题标题】：java.lang.Exception: java.lang.ClassCastException: org.apache.hadoop.io.Text cannot be cast to org.apache.hadoop.io.IntWritablejava.lang.Exception: java.lang.ClassCastException: org.apache.hadoop.io.Text 无法转换为 org.apache.hadoop.io.IntWritable
【发布时间】：2017-12-27 12:52:21
【问题描述】：

 public class PrimeMapper extends Mapper<LongWritable,IntWritable,IntWritable,NullWritable>
    {
         public void map(LongWritable k,IntWritable val,Context c) throws IOException, InterruptedException
            {
                 int v=val.get();
                 int i=2;
                 if(v==1)
                 c.write(new IntWritable(v), NullWritable.get());
                 for(i=2;i<v;i++)
                     {
                         if(v%i==0)
                         break;
                     }
                 if(v==i)
                 c.write(new IntWritable(v),NullWritable.get());
            }
   }

当我尝试运行此代码时，我收到类型转换错误。

【问题讨论】：

发布堆栈跟踪并指定哪一行抛出异常。
请添加堆栈跟踪
int v=val.get();这一行是错误的
不要发布或链接到文本截图。将文本复制并粘贴到问题本身中。（请注意，错误代码也应格式化为代码。）

标签： java hadoop exception mapper reducers

【解决方案1】：

当您使用默认输入格式 TextInputFormat（扩展 FileInputFormat<LongWritable, Text>）时，映射器预计 LongWritable 为 key 和 Text 为 value。如果您没有在程序中显式更改此设置，则您的映射器定义不正确。

正确的实现应该是这样的：

public class PrimeMapper extends Mapper<LongWritable,Text,IntWritable,NullWritable>{
   public void map(LongWritable k,Text val,Context c) throws IOException, InterruptedException{
     int v=Integer.parseInt(val.toString().trim());
     int i=2;
     if(v==1)
     c.write(new IntWritable(v), NullWritable.get());
     for(i=2;i<v;i++)
         {
             if(v%i==0)
             break;
         }
     if(v==i)
     c.write(new IntWritable(v),NullWritable.get());
  }
}

【讨论】：