Repository: hbase Updated Branches: refs/heads/master 4445b3046 -> 0cb2ab6a7
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/0cb2ab6a Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/0cb2ab6a Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/0cb2ab6a Branch: refs/heads/master Commit: 0cb2ab6a767aa143454d8b60c45f193423e3644c Parents: 4445b30 Author: anoopsjohn <[email protected]> Authored: Wed Aug 27 10:28:49 2014 +0530 Committer: anoopsjohn <[email protected]> Committed: Wed Aug 27 10:28:49 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/0cb2ab6a/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 087476f..aadcc5d 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);
