diff --git a/bookkeeper-server/src/test/java/org/apache/bookkeeper/replication/TestReplicationWorker.java b/bookkeeper-server/src/test/java/org/apache/bookkeeper/replication/TestReplicationWorker.java index 8caad1178c3..a9914233899 100644 --- a/bookkeeper-server/src/test/java/org/apache/bookkeeper/replication/TestReplicationWorker.java +++ b/bookkeeper-server/src/test/java/org/apache/bookkeeper/replication/TestReplicationWorker.java @@ -1246,6 +1246,7 @@ private void testRepairedNotAdheringPlacementPolicyLedgerFragments( baseClientConf.setProperty("reppDnsResolverClass", StaticDNSResolver.class.getName()); baseClientConf.setProperty("enforceStrictZoneawarePlacement", false); + bkc.close(); bkc = new BookKeeperTestClient(baseClientConf) { @Override protected EnsemblePlacementPolicy initializeEnsemblePlacementPolicy(ClientConfiguration conf, @@ -1357,6 +1358,8 @@ protected EnsemblePlacementPolicy initializeEnsemblePlacementPolicy(ClientConfig if (checkReplicationStats == null) { rw.shutdown(); } + baseConf.setRepairedPlacementPolicyNotAdheringBookieEnable(false); + bookKeeper.close(); } private EnsemblePlacementPolicy buildRackAwareEnsemblePlacementPolicy(List bookieIds) {