Repository: hbase Updated Branches: refs/heads/branch-1 642273bc2 -> d0d79f46c
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/d0d79f46 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/d0d79f46 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/d0d79f46 Branch: refs/heads/branch-1 Commit: d0d79f46c4cb6887ec2e620083937f6e8aa7d0d4 Parents: 642273b Author: ramkrishna <[email protected]> Authored: Mon Sep 28 10:05:12 2015 +0530 Committer: ramkrishna <[email protected]> Committed: Tue Sep 29 16:46:29 2015 +0530 ---------------------------------------------------------------------- .../regionserver/HBaseInterClusterReplicationEndpoint.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/d0d79f46/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 685e95c..0dfad0c 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),
