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

HBASE-9975 Not starting ReplicationSink when using custom implementation for the ReplicationSink 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1542472 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
anoopsamjohn 2013-11-16 07:40:51 +00:00
parent c2c6db5f00
commit b33e4daa2f
2 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
View File

@ -1612,10 +1612,13 @@ public class HRegionServer implements ClientProtos.ClientService.BlockingInterfa
if (this.replicationSourceHandler == this.replicationSinkHandler && if (this.replicationSourceHandler == this.replicationSinkHandler &&
this.replicationSourceHandler != null) { this.replicationSourceHandler != null) {
this.replicationSourceHandler.startReplicationService(); this.replicationSourceHandler.startReplicationService();
} else if (this.replicationSourceHandler != null) { } else {
this.replicationSourceHandler.startReplicationService(); if (this.replicationSourceHandler != null) {
} else if (this.replicationSinkHandler != null) { this.replicationSourceHandler.startReplicationService();
this.replicationSinkHandler.startReplicationService(); }
if (this.replicationSinkHandler != null) {
this.replicationSinkHandler.startReplicationService();
}
} }
// Start Server. This service is like leases in that it internally runs // Start Server. This service is like leases in that it internally runs

2
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java
View File

@ -220,7 +220,7 @@ public class ReplicationSink {
* @param rows list of actions * @param rows list of actions
* @throws IOException * @throws IOException
*/ */
private void batch(TableName tableName, Collection<List<Row>> allRows) throws IOException { protected void batch(TableName tableName, Collection<List<Row>> allRows) throws IOException {
if (allRows.isEmpty()) { if (allRows.isEmpty()) {
return; return;
} }