You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ra...@apache.org on 2015/09/28 06:36:24 UTC
hbase git commit: HBASE-14437 - ArithmeticException in
ReplicationInterClusterEndpoint (Ram)
Repository: hbase
Updated Branches:
refs/heads/master 526520de0 -> cfce91e51
HBASE-14437 - ArithmeticException in ReplicationInterClusterEndpoint (Ram)
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/cfce91e5
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/cfce91e5
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/cfce91e5
Branch: refs/heads/master
Commit: cfce91e514dcb570ca1b3131f340dc01cdbd5e56
Parents: 526520d
Author: ramkrishna <ra...@gmail.com>
Authored: Mon Sep 28 10:05:12 2015 +0530
Committer: ramkrishna <ra...@gmail.com>
Committed: Mon Sep 28 10:05:12 2015 +0530
----------------------------------------------------------------------
.../regionserver/HBaseInterClusterReplicationEndpoint.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/cfce91e5/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 1bf0802..4c719a9 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
@@ -162,6 +162,9 @@ public class HBaseInterClusterReplicationEndpoint extends HBaseReplicationEndpoi
peersSelected = true;
}
+ if (replicationSinkMgr.getSinks().size() == 0) {
+ return false;
+ }
// minimum of: configured threads, number of 100-waledit batches,
// and number of current sinks
int n = Math.min(Math.min(this.maxThreads, entries.size()/100+1),