[ https://issues.apache.org/jira/browse/HBASE-14557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14952617#comment-14952617 ]
ramkrishna.s.vasudevan commented on HBASE-14557: ------------------------------------------------ bq.We need this fix in all used places.. You can see now this ensureKeyValue is used only with MR code( mapper, reducers etc) All these places KeyValue is the value type as specified as in WALPlayer case Yes, this is what I too suspect. In MR code we may have to add a new API in KVUtil like ensureKeyValue to solve this which just always creates a new KV from the incoming bytes? > MapReduce WALPlayer issue with NoTagsKeyValue > --------------------------------------------- > > Key: HBASE-14557 > URL: https://issues.apache.org/jira/browse/HBASE-14557 > Project: HBase > Issue Type: Bug > Affects Versions: 1.2.0 > Reporter: Jerry He > Assignee: Anoop Sam John > Priority: Blocker > Fix For: 2.0.0, 1.2.0, 1.3.0 > > Attachments: HBASE-14557.patch, HBASE-14557.patch, > HBASE-14557_V2.patch, HBASE-14557_branch-1.2.patch, HBASE-14557_branch-1.patch > > > Running MapReduce WALPlayer to convert WAL into HFiles: > {noformat} > 15/10/05 20:28:08 INFO mapred.JobClient: Task Id : > attempt_201508031611_0029_m_000000_0, Status : FAILED > java.io.IOException: Type mismatch in value from map: expected > org.apache.hadoop.hbase.KeyValue, recieved > org.apache.hadoop.hbase.NoTagsKeyValue > at > org.apache.hadoop.mapred.MapTask$MapOutputBuffer.collect(MapTask.java:997) > at > org.apache.hadoop.mapred.MapTask$NewOutputCollector.write(MapTask.java:689) > at > org.apache.hadoop.mapreduce.task.TaskInputOutputContextImpl.write(TaskInputOutputContextImpl.java:89) > at > org.apache.hadoop.mapreduce.lib.map.WrappedMapper$Context.write(WrappedMapper.java:112) > at > org.apache.hadoop.hbase.mapreduce.WALPlayer$WALKeyValueMapper.map(WALPlayer.java:111) > at > org.apache.hadoop.hbase.mapreduce.WALPlayer$WALKeyValueMapper.map(WALPlayer.java:96) > at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:140) > at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:751) > at org.apache.hadoop.mapred.MapTask.run(MapTask.java:368) > at org.apache.hadoop.mapred.Child$4.run(Child.java:255) > at > java.security.AccessController.doPrivileged(AccessController.java:369) > at javax.security.auth.Subject.doAs(Subject.java:572) > at > org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1502) > at org.apache.hadoop.mapred.Child.main(Child.java:249) > {noformat} -- This message was sent by Atlassian JIRA (v6.3.4#6332)