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:03 UTC
svn commit: r1543502 - in
/hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase:
regionserver/HRegionServer.java replication/regionserver/ReplicationSink.java
Author: anoopsamjohn
Date: Tue Nov 19 17:11:02 2013
New Revision: 1543502
URL: http://svn.apache.org/r1543502
Log:
HBASE-9995 Not stopping ReplicationSink when using custom implementation for the ReplicationSink
Modified:
hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java
Modified: hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java?rev=1543502&r1=1543501&r2=1543502&view=diff
==============================================================================
--- hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java (original)
+++ hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java Tue Nov 19 17:11:02 2013
@@ -1815,10 +1815,13 @@ public class HRegionServer implements Cl
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.96/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java?rev=1543502&r1=1543501&r2=1543502&view=diff
==============================================================================
--- hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java (original)
+++ hbase/branches/0.96/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java Tue Nov 19 17:11:02 2013
@@ -217,7 +217,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(TableName tableName, Collection<List<Row>> allRows) throws IOException {