[
https://issues.apache.org/jira/browse/HBASE-7215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13505269#comment-13505269
]
Lars Hofhansl commented on HBASE-7215:
--------------------------------------
I have found the problem with M/R. protobuf's parseFrom apparently wants to
read until EOF. But in this case many messages are serialized over the same
stream. So needed to use parseDelimitedFrom and writeDelimitedTo. Also had to
change TableOutputFormat to accept Mutations instead of Writables.
I also changed the generics signature of TableReducer and IdentityReducer. It
might not be as bad as we think as these always only supported Put and Delete,
so instead of Writable they just need to be declared with Mutation.
New patch coming up momentarily.
> Put, Delete, Increment, and Result still implement Writable
> -----------------------------------------------------------
>
> Key: HBASE-7215
> URL: https://issues.apache.org/jira/browse/HBASE-7215
> Project: HBase
> Issue Type: Bug
> Reporter: Lars Hofhansl
> Assignee: Lars Hofhansl
> Priority: Blocker
> Fix For: 0.96.0
>
> Attachments: 7215-v2.txt, 7215v3_mutableresult.txt, 7215v3.txt,
> 7215v3.txt, 7251-SKETCH.txt, MutableResult.java
>
>
> Making blocker as suggested by Stack.
> At least the following still use Put/Delete as writables.
> * IdentityTableReduce.java
> * MultiPut.java
> * HRegionServer.checkAndMutate
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
