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:56 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1 642273bc2 -> d0d79f46c


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/d0d79f46
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/d0d79f46
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/d0d79f46

Branch: refs/heads/branch-1
Commit: d0d79f46c4cb6887ec2e620083937f6e8aa7d0d4
Parents: 642273b
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:46:29 2015 +0530

----------------------------------------------------------------------
 .../regionserver/HBaseInterClusterReplicationEndpoint.java        | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/d0d79f46/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 685e95c..0dfad0c 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),


Mime
View raw message