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

HBASE-12971 Replication stuck due to large default value for replication.source.maxretriesmultiplier.

Browse Source
This commit is contained in:
Lars Hofhansl 2015-02-13 22:18:51 -08:00
parent 432b2197fd
commit 05e0b46d52
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java
View File

@ -76,9 +76,9 @@ public class HBaseInterClusterReplicationEndpoint extends HBaseReplicationEndpoi
super.init(context); super.init(context);
this.conf = HBaseConfiguration.create(ctx.getConfiguration()); this.conf = HBaseConfiguration.create(ctx.getConfiguration());
decorateConf(); decorateConf();
this.maxRetriesMultiplier = this.conf.getInt("replication.source.maxretriesmultiplier", 10); this.maxRetriesMultiplier = this.conf.getInt("replication.source.maxretriesmultiplier", 300);
this.socketTimeoutMultiplier = this.conf.getInt("replication.source.socketTimeoutMultiplier", this.socketTimeoutMultiplier = this.conf.getInt("replication.source.socketTimeoutMultiplier",
maxRetriesMultiplier * maxRetriesMultiplier); maxRetriesMultiplier);
// TODO: This connection is replication specific or we should make it particular to // TODO: This connection is replication specific or we should make it particular to
// replication and make replication specific settings such as compression or codec to use // replication and make replication specific settings such as compression or codec to use
// passing Cells. // passing Cells.