diff options
author | jonmv <venstad@gmail.com> | 2022-09-30 10:01:40 +0200 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2022-10-10 12:33:57 +0200 |
commit | b26f014bc004e2d837e8100161ee70fe7d612fa6 (patch) | |
tree | 6e59796cbc2857d4dc636e7350870ed3df3fbe33 /zookeeper-server | |
parent | ac20b0fb6f3140a5b144b34e6d3248b4bff014c1 (diff) |
Re-enable test which was probably stabilised by fixing ZOOKEEPER-4541
Diffstat (limited to 'zookeeper-server')
-rw-r--r-- | zookeeper-server/zookeeper-server/src/test/java/com/yahoo/vespa/zookeper/VespaZooKeeperTest.java | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/zookeeper-server/zookeeper-server/src/test/java/com/yahoo/vespa/zookeper/VespaZooKeeperTest.java b/zookeeper-server/zookeeper-server/src/test/java/com/yahoo/vespa/zookeper/VespaZooKeeperTest.java index db643d76e0d..3a125d72a89 100644 --- a/zookeeper-server/zookeeper-server/src/test/java/com/yahoo/vespa/zookeper/VespaZooKeeperTest.java +++ b/zookeeper-server/zookeeper-server/src/test/java/com/yahoo/vespa/zookeper/VespaZooKeeperTest.java @@ -38,6 +38,9 @@ import static java.util.concurrent.TimeUnit.SECONDS; import static java.util.stream.Collectors.toList; import static org.junit.Assert.assertEquals; +/** + * @author jonmv + */ public class VespaZooKeeperTest { static final Path tempDirRoot = getTmpDir(); @@ -45,18 +48,17 @@ public class VespaZooKeeperTest { /** * Performs dynamic reconfiguration of ZooKeeper servers. - * + * <p> * First, a cluster of 3 servers is set up, and some data is written to it. * Then, 3 new servers are added, and the first 3 marked for retirement; * this should force the quorum to move the 3 new servers, but not disconnect the old ones. * Next, the old servers are removed. * Then, the cluster is reduced to size 1. * Finally, the cluster grows to size 3 again. - * + * <p> * Throughout all of this, quorum should remain, and the data should remain the same. */ @Test(timeout = 120_000) - @Ignore // Unstable, some ZK server keeps resetting connections sometimes. public void testReconfiguration() throws ExecutionException, InterruptedException, IOException, KeeperException, TimeoutException { List<ZooKeeper> keepers = new ArrayList<>(); for (int i = 0; i < 8; i++) keepers.add(new ZooKeeper()); @@ -126,7 +128,7 @@ public class VespaZooKeeperTest { static String writeData(ZookeeperServerConfig config) throws IOException, InterruptedException, KeeperException { try (ZooKeeperAdmin admin = createAdmin(config)) { List<ACL> acl = ZooDefs.Ids.OPEN_ACL_UNSAFE; - String node = admin.create("/test-node", "hi".getBytes(UTF_8), acl, CreateMode.EPHEMERAL_SEQUENTIAL); + String node = admin.create("/test-node", "hi".getBytes(UTF_8), acl, CreateMode.PERSISTENT_SEQUENTIAL); String read = new String(admin.getData(node, false, new Stat()), UTF_8); assertEquals("hi", read); return node; |