Repository: hbase Updated Branches: refs/heads/master c817aa386 -> 867a5ea18
HBASE-14766 In WALEntryFilter, cell.getFamily() needs to be replaced with the new low-cost implementation (huaxiang sun) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/867a5ea1 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/867a5ea1 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/867a5ea1 Branch: refs/heads/master Commit: 867a5ea188269619c3472a84bf97f5676ba3bec2 Parents: c817aa3 Author: tedyu <[email protected]> Authored: Tue Nov 10 14:18:59 2015 -0800 Committer: tedyu <[email protected]> Committed: Tue Nov 10 14:18:59 2015 -0800 ---------------------------------------------------------------------- .../apache/hadoop/hbase/replication/TableCfWALEntryFilter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/867a5ea1/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/TableCfWALEntryFilter.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/TableCfWALEntryFilter.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/TableCfWALEntryFilter.java index 0cbbcef..642ee8a 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/TableCfWALEntryFilter.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/TableCfWALEntryFilter.java @@ -25,7 +25,6 @@ import java.util.Map; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.Cell; -import org.apache.hadoop.hbase.CellUtil; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.wal.WAL.Entry; @@ -63,7 +62,8 @@ public class TableCfWALEntryFilter implements WALEntryFilter { Cell cell = cells.get(i); // ignore(remove) kv if its cf isn't in the replicable cf list // (empty cfs means all cfs of this table are replicable) - if ((cfs != null && !cfs.contains(Bytes.toString(CellUtil.cloneFamily(cell))))) { + if ((cfs != null) && !cfs.contains(Bytes.toString( + cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()))) { cells.remove(i); } }
