Index: hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java =================================================================== --- hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (revision 1381030) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -403,6 +403,9 @@ seenEntries++; // Remove all KVs that should not be replicated HLogKey logKey = entry.getKey(); + // make sure ipc send the entry not in compression mode + edit.setCompressionContext(null); + logKey.setCompressionContext(null); // don't replicate if the log entries originated in the peer if (!logKey.getClusterId().equals(peerClusterId)) { removeNonReplicableEdits(edit);