Index: src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java (revision 1462711) +++ src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java (working copy) @@ -126,7 +126,9 @@ public void join() { if (this.replication) { this.replicationManager.join(); - this.replicationSink.stopReplicationSinkServices(); + if (this.replicationSink != null) { + this.replicationSink.stopReplicationSinkServices(); + } } }