hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From la...@apache.org
Subject [3/3] hbase git commit: HBASE-12971 Replication stuck due to large default value for replication.source.maxretriesmultiplier.
Date Sat, 14 Feb 2015 06:18:54 GMT
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/255dc4e5
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/255dc4e5
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/255dc4e5

Branch: refs/heads/branch-1.0
Commit: 255dc4e58a2c1935cb07ac8e89148a0eeee52445
Parents: bd6fbea
Author: Lars Hofhansl <larsh@apache.org>
Authored: Fri Feb 13 22:18:51 2015 -0800
Committer: Lars Hofhansl <larsh@apache.org>
Committed: Fri Feb 13 22:19:49 2015 -0800

----------------------------------------------------------------------
 .../regionserver/HBaseInterClusterReplicationEndpoint.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/255dc4e5/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.


Mime
View raw message