Fix transport tests when using zookeeper

reactiverse · Aug 8, 2023 · c1937b7 · c1937b7
1 parent 3e93f98
commit c1937b7
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 17 deletions.
diff --git a/...t-client-mutiny/src/test/java/io/reactiverse/pinot/client/mutiny/VertxConnectionTest.java b/...t-client-mutiny/src/test/java/io/reactiverse/pinot/client/mutiny/VertxConnectionTest.java
@@ -23,7 +23,6 @@
 import org.apache.pinot.client.ResultSetGroup;
 import org.apache.pinot.client.VertxPinotClientTransport;
 import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.testcontainers.containers.GenericContainer;
@@ -47,7 +46,7 @@ public class VertxConnectionTest {
     @Container
     public static GenericContainer<?> pinot = new GenericContainer<>(DockerImageName.parse("apachepinot/pinot:0.12.0"))
             .withCommand("QuickStart -type batch")
-            .withExposedPorts(2181, 8000, 9000)
+            .withExposedPorts(2123, 8000, 9000)
             .waitingFor(Wait.forLogMessage(".*Offline quickstart setup complete.*\\n", 1))
             .withStartupTimeout(Duration.ofSeconds(600))
             .withReuse(true);
@@ -129,9 +128,8 @@ public void testVertxTransportWithController(VertxTestContext testContext) {
     }
 
     @Test
-    @Disabled
     public void testVertxTransportWithZookeeper(VertxTestContext testContext) {
-        String zookeeperUrl = "localhost:" + pinot.getMappedPort(2181) + "/QuickStartCluster";
+        String zookeeperUrl = "localhost:" + pinot.getMappedPort(2123) + "/QuickStartCluster";
         VertxPinotClientTransport transport = new VertxPinotClientTransport(vertx.getDelegate());
         VertxConnection connection = VertxConnectionFactory.fromZookeeper(vertx, zookeeperUrl, transport);
         executeQueryTest(testContext, connection);

diff --git a/...ient-rxjava2/src/test/java/io/reactiverse/pinot/client/reactivex/VertxConnectionTest.java b/...ient-rxjava2/src/test/java/io/reactiverse/pinot/client/reactivex/VertxConnectionTest.java
@@ -23,7 +23,6 @@
 import org.apache.pinot.client.ResultSetGroup;
 import org.apache.pinot.client.VertxPinotClientTransport;
 import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.testcontainers.containers.GenericContainer;
@@ -47,7 +46,7 @@ public class VertxConnectionTest {
     @Container
     public static GenericContainer<?> pinot = new GenericContainer<>(DockerImageName.parse("apachepinot/pinot:0.12.0"))
             .withCommand("QuickStart -type batch")
-            .withExposedPorts(2181, 8000, 9000)
+            .withExposedPorts(2123, 8000, 9000)
             .waitingFor(Wait.forLogMessage(".*Offline quickstart setup complete.*\\n", 1))
             .withStartupTimeout(Duration.ofSeconds(600))
             .withReuse(true);
@@ -127,9 +126,8 @@ public void testVertxTransportWithController(VertxTestContext testContext) {
     }
 
     @Test
-    @Disabled
     public void testVertxTransportWithZookeeper(VertxTestContext testContext) {
-        String zookeeperUrl = "localhost:" + pinot.getMappedPort(2181) + "/QuickStartCluster";
+        String zookeeperUrl = "localhost:" + pinot.getMappedPort(2123) + "/QuickStartCluster";
         VertxPinotClientTransport transport = new VertxPinotClientTransport(vertx.getDelegate());
         VertxConnection connection = VertxConnectionFactory.fromZookeeper(vertx, zookeeperUrl, transport);
         executeQueryTest(testContext, connection);

diff --git a/...client-rxjava3/src/test/java/io/reactiverse/pinot/client/rxjava3/VertxConnectionTest.java b/...client-rxjava3/src/test/java/io/reactiverse/pinot/client/rxjava3/VertxConnectionTest.java
@@ -23,7 +23,6 @@
 import org.apache.pinot.client.ResultSetGroup;
 import org.apache.pinot.client.VertxPinotClientTransport;
 import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.testcontainers.containers.GenericContainer;
@@ -47,7 +46,7 @@ public class VertxConnectionTest {
     @Container
     public static GenericContainer<?> pinot = new GenericContainer<>(DockerImageName.parse("apachepinot/pinot:0.12.0"))
             .withCommand("QuickStart -type batch")
-            .withExposedPorts(2181, 8000, 9000)
+            .withExposedPorts(2123, 8000, 9000)
             .waitingFor(Wait.forLogMessage(".*Offline quickstart setup complete.*\\n", 1))
             .withStartupTimeout(Duration.ofSeconds(600))
             .withReuse(true);
@@ -127,9 +126,8 @@ public void testVertxTransportWithController(VertxTestContext testContext) {
     }
 
     @Test
-    @Disabled
     public void testVertxTransportWithZookeeper(VertxTestContext testContext) {
-        String zookeeperUrl = "localhost:" + pinot.getMappedPort(2181) + "/QuickStartCluster";
+        String zookeeperUrl = "localhost:" + pinot.getMappedPort(2123) + "/QuickStartCluster";
         VertxPinotClientTransport transport = new VertxPinotClientTransport(vertx.getDelegate());
         VertxConnection connection = VertxConnectionFactory.fromZookeeper(vertx, zookeeperUrl, transport);
         executeQueryTest(testContext, connection);

diff --git a/pinot-client/src/test/java/io/reactiverse/pinot/client/VertxConnectionTest.java b/pinot-client/src/test/java/io/reactiverse/pinot/client/VertxConnectionTest.java
@@ -23,7 +23,6 @@
 import org.apache.pinot.client.ResultSetGroup;
 import org.apache.pinot.client.VertxPinotClientTransport;
 import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.testcontainers.containers.GenericContainer;
@@ -47,7 +46,7 @@ public class VertxConnectionTest {
     @Container
     public static GenericContainer<?> pinot = new GenericContainer<>(DockerImageName.parse("apachepinot/pinot:0.12.0"))
             .withCommand("QuickStart -type batch")
-            .withExposedPorts(2181, 8000, 9000)
+            .withExposedPorts(2123, 8000, 9000)
             .waitingFor(Wait.forLogMessage(".*Offline quickstart setup complete.*\\n", 1))
             .withStartupTimeout(Duration.ofSeconds(600))
             .withReuse(true);
@@ -123,12 +122,11 @@ public void testVertxTransportWithController(VertxTestContext testContext) {
     }
 
     @Test
-    @Disabled
     public void testVertxTransportWithZookeeper(VertxTestContext testContext) {
-        String zookeeperUrl = "localhost:" + pinot.getMappedPort(2181) + "/QuickStartCluster";
+        String zookeeperUrl = "localhost:" + pinot.getMappedPort(2123) + "/QuickStartCluster";
         VertxPinotClientTransport transport = new VertxPinotClientTransport(vertx);
         VertxConnection connection = VertxConnectionFactory.fromZookeeper(vertx, zookeeperUrl, transport);
         executeQueryTest(testContext, connection);
     }
 
-}
+}