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 <[email protected]> Authored: Mon Sep 28 10:05:12 2015 +0530 Committer: ramkrishna <[email protected]> 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),
