You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by la...@apache.org on 2015/02/14 07:18:53 UTC
[2/3] hbase git commit: HBASE-12971 Replication stuck due to large
default value for replication.source.maxretriesmultiplier.
HBASE-12971 Replication stuck due to large default value for replication.source.maxretriesmultiplier.
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/05e0b46d
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/05e0b46d
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/05e0b46d
Branch: refs/heads/branch-1
Commit: 05e0b46d520ae166f8e201cf79383e813b884716
Parents: 432b219
Author: Lars Hofhansl <la...@apache.org>
Authored: Fri Feb 13 22:18:51 2015 -0800
Committer: Lars Hofhansl <la...@apache.org>
Committed: Fri Feb 13 22:19:15 2015 -0800
----------------------------------------------------------------------
.../regionserver/HBaseInterClusterReplicationEndpoint.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/05e0b46d/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java
index 397044d..95c253d 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java
@@ -76,9 +76,9 @@ public class HBaseInterClusterReplicationEndpoint extends HBaseReplicationEndpoi
super.init(context);
this.conf = HBaseConfiguration.create(ctx.getConfiguration());
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",
- maxRetriesMultiplier * maxRetriesMultiplier);
+ maxRetriesMultiplier);
// 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
// passing Cells.