[
https://issues.apache.org/jira/browse/HBASE-16504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438363#comment-15438363
]
Phil Yang commented on HBASE-16504:
-----------------------------------
Hi
{code}
if (CellUtil.isDelete(cell)) {
((Delete) m).addDeleteMarker(cell);
} else {
((Put) m).add(cell);
}
{code}
I think we keep the ts here?
> Replication is not preserving the timestamp of the cell
> -------------------------------------------------------
>
> Key: HBASE-16504
> URL: https://issues.apache.org/jira/browse/HBASE-16504
> Project: HBase
> Issue Type: Bug
> Components: Replication
> Reporter: Sai Teja Ranuva
> Labels: replication, replication-testing
>
> The Replication procedure in ReplicationSink.replicateEntries() method is not
> preserving the timestamp of the cell.
> Pointer to the code:
> m = CellUtil.isDelete(cell) ? new Delete(cell.getRowArray(),
> cell.getRowOffset(),cell.getRowLength()) : new Put(cell.getRowArray(),
> cell.getRowOffset(),cell.getRowLength());
> The Put and Delete constructors called here assign the timestamp with
> HConstants.LATEST_TIMESTAMP. Instead we need to keep the timestamp of the
> cell here.
> Also there doesn't seem to be a test which checks if replication is
> preserving the timestamp.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
