HBASE-14437 - ArithmeticException in ReplicationInterClusterEndpoint (Ram)

2015-09-28 10:05:12 +05:30 · 2015-09-28 10:05:12 +05:30 · d0d79f46c4
parent 642273bc2a
commit d0d79f46c4
1 changed files with 3 additions and 0 deletions
--- 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),