summaryrefslogtreecommitdiffstats
path: root/zookeeper-server
diff options
context:
space:
mode:
authorjonmv <venstad@gmail.com>2022-09-30 10:01:40 +0200
committerjonmv <venstad@gmail.com>2022-10-10 12:33:57 +0200
commitb26f014bc004e2d837e8100161ee70fe7d612fa6 (patch)
tree6e59796cbc2857d4dc636e7350870ed3df3fbe33 /zookeeper-server
parentac20b0fb6f3140a5b144b34e6d3248b4bff014c1 (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.java10
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;