Repository: hbase Updated Branches: refs/heads/branch-1 2ef6d03e5 -> 9bd9b26a0
HBASE-11820 ReplicationSource : Set replication codec class as RPC codec class on a clonned Configuration. Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/9bd9b26a Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/9bd9b26a Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/9bd9b26a Branch: refs/heads/branch-1 Commit: 9bd9b26a0ee19cb49721b10a5121f101c72a7d58 Parents: 2ef6d03 Author: anoopsjohn <anoopsamj...@gmail.com> Authored: Wed Aug 27 10:29:51 2014 +0530 Committer: anoopsjohn <anoopsamj...@gmail.com> Committed: Wed Aug 27 10:29:51 2014 +0530 ---------------------------------------------------------------------- .../hadoop/hbase/replication/regionserver/ReplicationSource.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/9bd9b26a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java index 720d0ee..6451f91 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java @@ -37,6 +37,7 @@ import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.CellUtil; +import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.Stoppable; @@ -154,7 +155,7 @@ public class ReplicationSource extends Thread final MetricsSource metrics) throws IOException { this.stopper = stopper; - this.conf = conf; + this.conf = HBaseConfiguration.create(conf); decorateConf(); this.replicationQueueSizeCapacity = this.conf.getLong("replication.source.size.capacity", 1024*1024*64);
