hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ramkris...@apache.org
Subject hbase git commit: HBASE-14437 - ArithmeticException in ReplicationInterClusterEndpoint (Ram)
Date Tue, 29 Sep 2015 11:16:06 GMT
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 <ramkrishna.s.vasudevan@gmail.com>
Authored: Mon Sep 28 10:05:12 2015 +0530
Committer: ramkrishna <ramkrishna.s.vasudevan@gmail.com>
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),


Mime
View raw message