You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by an...@apache.org on 2013/11/19 18:11:29 UTC
svn commit: r1543503 - in
/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase:
regionserver/HRegionServer.java replication/regionserver/ReplicationSink.java
Author: anoopsamjohn
Date: Tue Nov 19 17:11:29 2013
New Revision: 1543503
URL: http://svn.apache.org/r1543503
Log:
HBASE-9995 Not stopping ReplicationSink when using custom implementation for the ReplicationSink
Modified:
hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java
Modified: hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java?rev=1543503&r1=1543502&r2=1543503&view=diff
==============================================================================
--- hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java (original)
+++ hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java Tue Nov 19 17:11:29 2013
@@ -1975,10 +1975,13 @@ public class HRegionServer implements HR
if (this.replicationSourceHandler != null &&
this.replicationSourceHandler == this.replicationSinkHandler) {
this.replicationSourceHandler.stopReplicationService();
- } else if (this.replicationSourceHandler != null) {
- this.replicationSourceHandler.stopReplicationService();
- } else if (this.replicationSinkHandler != null) {
- this.replicationSinkHandler.stopReplicationService();
+ } else {
+ if (this.replicationSourceHandler != null) {
+ this.replicationSourceHandler.stopReplicationService();
+ }
+ if (this.replicationSinkHandler != null) {
+ this.replicationSinkHandler.stopReplicationService();
+ }
}
}
Modified: hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java?rev=1543503&r1=1543502&r2=1543503&view=diff
==============================================================================
--- hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java (original)
+++ hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java Tue Nov 19 17:11:29 2013
@@ -200,7 +200,7 @@ public class ReplicationSink {
/**
* Do the changes and handle the pool
* @param tableName table to insert into
- * @param rows list of actions
+ * @param allRows list of actions
* @throws IOException
*/
protected void batch(byte[] tableName, Collection<List<Row>> allRows) throws IOException {