Repository: hbase Updated Branches: refs/heads/branch-1.2 527a21061 -> b5608ba75
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/b5608ba7 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/b5608ba7 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/b5608ba7 Branch: refs/heads/branch-1.2 Commit: b5608ba7561850aa64484827d56eb126643f6026 Parents: 527a210 Author: ramkrishna <[email protected]> Authored: Mon Sep 28 10:05:12 2015 +0530 Committer: ramkrishna <[email protected]> Committed: Tue Sep 29 16:45:37 2015 +0530 ---------------------------------------------------------------------- .../regionserver/HBaseInterClusterReplicationEndpoint.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/b5608ba7/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 eb42e69..44ec804 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 @@ -161,6 +161,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),
