首页 > 其他 > 详细

Hadoop中java.lang.ClassCastException: partition解决方法

时间:2014-03-12 03:54:14      阅读:312      评论:0      收藏:0      [点我收藏+]

java.lang.ClassCastException: partition.KpiWritable cannot be cast to org.apache.hadoop.io.LongWritable

at partition.KpiApp$MyPartition.getPartition(KpiApp.java:1)

at org.apache.hadoop.mapred.MapTask$NewOutputCollector.write(MapTask.java:691)

at org.apache.hadoop.mapreduce.TaskInputOutputContext.write(TaskInputOutputContext.java:80)

at partition.KpiApp$MyMapper.map(KpiApp.java:102)

at partition.KpiApp$MyMapper.map(KpiApp.java:1)

at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:144)

at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:764)

at org.apache.hadoop.mapred.MapTask.run(MapTask.java:370)

at org.apache.hadoop.mapred.Child$4.run(Child.java:255)

at java.security.AccessController.doPrivileged(Native Method)

at javax.security.auth.Subject.doAs(Subject.java:396)

at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInforma

类型转换错误,由于自定义的Partitioner类继承HashPartitioner泛型中类型写错,该类型是跟K2,V2的类型一致。

Hadoop中java.lang.ClassCastException: partition解决方法,布布扣,bubuko.com

Hadoop中java.lang.ClassCastException: partition解决方法

原文:http://www.cnblogs.com/luguoyuanf/p/3594461.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!