Repository: curator Updated Branches: refs/heads/CURATOR-411 5407746c3 -> 0d1aa7ed1
Have to call setReconfigEnabled(true) and set the super-user Auth to get reconfig to work Project: http://git-wip-us.apache.org/repos/asf/curator/repo Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/0d1aa7ed Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/0d1aa7ed Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/0d1aa7ed Branch: refs/heads/CURATOR-411 Commit: 0d1aa7ed1f3fef2b9cdb1e3a7f15d6e6ae85dac0 Parents: 5407746 Author: randgalt <[email protected]> Authored: Mon May 8 19:37:06 2017 +0200 Committer: randgalt <[email protected]> Committed: Mon May 8 19:37:06 2017 +0200 ---------------------------------------------------------------------- .../apache/curator/framework/imps/TestReconfiguration.java | 9 +++++++++ 1 file changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/curator/blob/0d1aa7ed/curator-framework/src/test/java/org/apache/curator/framework/imps/TestReconfiguration.java ---------------------------------------------------------------------- diff --git a/curator-framework/src/test/java/org/apache/curator/framework/imps/TestReconfiguration.java b/curator-framework/src/test/java/org/apache/curator/framework/imps/TestReconfiguration.java index 7565590..53b9c5f 100644 --- a/curator-framework/src/test/java/org/apache/curator/framework/imps/TestReconfiguration.java +++ b/curator-framework/src/test/java/org/apache/curator/framework/imps/TestReconfiguration.java @@ -37,6 +37,7 @@ import org.apache.zookeeper.WatchedEvent; import org.apache.zookeeper.Watcher; import org.apache.zookeeper.data.Stat; import org.apache.zookeeper.server.quorum.QuorumPeer; +import org.apache.zookeeper.server.quorum.QuorumPeerConfig; import org.apache.zookeeper.server.quorum.flexible.QuorumMaj; import org.apache.zookeeper.server.quorum.flexible.QuorumVerifier; import org.testng.Assert; @@ -61,12 +62,18 @@ public class TestReconfiguration extends BaseClassForTests private TestingCluster cluster; private EnsembleProvider ensembleProvider; + private static final String superUserPasswordDigest = "curator-test:zghsj3JfJqK7DbWf0RQ1BgbJH9w="; // ran from DigestAuthenticationProvider.generateDigest(superUserPassword); + private static final String superUserPassword = "curator-test"; + @BeforeMethod @Override public void setup() throws Exception { super.setup(); + QuorumPeerConfig.setReconfigEnabled(true); + System.setProperty("zookeeper.DigestAuthenticationProvider.superDigest", superUserPasswordDigest); + CloseableUtils.closeQuietly(server); server = null; cluster = new TestingCluster(3); @@ -79,6 +86,7 @@ public class TestReconfiguration extends BaseClassForTests { CloseableUtils.closeQuietly(cluster); ensembleProvider = null; + System.clearProperty("zookeeper.DigestAuthenticationProvider.superDigest"); super.teardown(); } @@ -350,6 +358,7 @@ public class TestReconfiguration extends BaseClassForTests .ensembleProvider(ensembleProvider) .sessionTimeoutMs(timing.session()) .connectionTimeoutMs(timing.connection()) + .authorization("digest", superUserPassword.getBytes()) .retryPolicy(new ExponentialBackoffRetry(timing.forSleepingABit().milliseconds(), 3)) .build(); }
