@@ -141,10 +141,11 @@ public String explainFailure() throws Exception {
141141 @ Test
142142 public void testCustomReplicationEndpoint () throws Exception {
143143 // test installing a custom replication endpoint other than the default one.
144- hbaseAdmin .addReplicationPeer ("testCustomReplicationEndpoint" , ReplicationPeerConfig .newBuilder ()
145- .setClusterKey (ZKConfig .getZooKeeperClusterKey (CONF1 ))
146- .setReplicationEndpointImpl (ReplicationEndpointForTest .class .getName ())
147- .build ());
144+ hbaseAdmin .addReplicationPeer ("testCustomReplicationEndpoint" ,
145+ ReplicationPeerConfig .newBuilder ()
146+ .setClusterKey (ZKConfig .getZooKeeperClusterKey (CONF1 ))
147+ .setReplicationEndpointImpl (ReplicationEndpointForTest .class .getName ())
148+ .build ());
148149
149150 // check whether the class has been constructed and started
150151 Waiter .waitFor (CONF1 , 60000 , new Waiter .Predicate <Exception >() {
@@ -188,8 +189,7 @@ public void testReplicationEndpointReturnsFalseOnReplicate() throws Exception {
188189 ReplicationPeerConfig .newBuilder ()
189190 .setClusterKey (ZKConfig .getZooKeeperClusterKey (CONF1 ))
190191 .setReplicationEndpointImpl (ReplicationEndpointReturningFalse .class .getName ())
191- .build ()
192- );
192+ .build ());
193193 // This test is flakey and then there is so much stuff flying around in here its, hard to
194194 // debug. Peer needs to be up for the edit to make it across. This wait on
195195 // peer count seems to be a hack that has us not progress till peer is up.
@@ -242,8 +242,8 @@ public void testInterClusterReplication() throws Exception {
242242 hbaseAdmin .addReplicationPeer (id ,
243243 ReplicationPeerConfig .newBuilder ()
244244 .setClusterKey (ZKConfig .getZooKeeperClusterKey (CONF2 ))
245- .setReplicationEndpointImpl (InterClusterReplicationEndpointForTest .class .getName ()). build ()
246- );
245+ .setReplicationEndpointImpl (InterClusterReplicationEndpointForTest .class .getName ())
246+ . build () );
247247
248248 final int numEdits = totEdits ;
249249 Waiter .waitFor (CONF1 , 30000 , new Waiter .ExplainingPredicate <Exception >() {
0 commit comments