Apache/hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-14437 - ArithmeticException in ReplicationInterClusterEndpoint (Ram)

Browse Source
This commit is contained in:
ramkrishna 2015-09-28 10:05:12 +05:30
parent 526520de0a
commit cfce91e514
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java
View File

@ -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),