Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-11820 ReplicationSource : Set replication codec class as RPC codec class on a clonned Configuration.

This commit is contained in:
anoopsjohn 2014-08-27 10:28:49 +05:30
parent 4445b30464
commit 0cb2ab6a76
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
View File

@ -37,6 +37,7 @@ import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path; import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hbase.CellUtil; import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.HConstants;
import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.Stoppable; import org.apache.hadoop.hbase.Stoppable;
@ -154,7 +155,7 @@ public class ReplicationSource extends Thread
final MetricsSource metrics) final MetricsSource metrics)
throws IOException { throws IOException {
this.stopper = stopper; this.stopper = stopper;
this.conf = conf; this.conf = HBaseConfiguration.create(conf);
decorateConf(); decorateConf();
this.replicationQueueSizeCapacity = this.replicationQueueSizeCapacity =
this.conf.getLong("replication.source.size.capacity", 1024*1024*64); this.conf.getLong("replication.source.size.capacity", 1024*1024*64);