hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From anoopsamj...@apache.org
Subject git commit: HBASE-11820 ReplicationSource : Set replication codec class as RPC codec class on a clonned Configuration.
Date Wed, 27 Aug 2014 05:00:13 GMT
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 <anoopsamjohn@gmail.com>
Authored: Wed Aug 27 10:29:51 2014 +0530
Committer: anoopsjohn <anoopsamjohn@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);


Mime
View raw message