diff --git a/airbyte-integrations/connectors/destination-cassandra/src/test-integration/java/io/airbyte/integrations/destination/cassandra/CassandraDestinationAcceptanceTest.java b/airbyte-integrations/connectors/destination-cassandra/src/test-integration/java/io/airbyte/integrations/destination/cassandra/CassandraDestinationAcceptanceTest.java index 3e32df81ce7b..d78eb667bd13 100644 --- a/airbyte-integrations/connectors/destination-cassandra/src/test-integration/java/io/airbyte/integrations/destination/cassandra/CassandraDestinationAcceptanceTest.java +++ b/airbyte-integrations/connectors/destination-cassandra/src/test-integration/java/io/airbyte/integrations/destination/cassandra/CassandraDestinationAcceptanceTest.java @@ -7,6 +7,7 @@ import com.fasterxml.jackson.databind.JsonNode; import io.airbyte.commons.json.Jsons; import io.airbyte.integrations.standardtest.destination.DestinationAcceptanceTest; +import io.airbyte.integrations.util.HostPortResolver; import java.util.Comparator; import java.util.List; import java.util.stream.Collectors; @@ -16,8 +17,6 @@ public class CassandraDestinationAcceptanceTest extends DestinationAcceptanceTest { - private static final Logger LOGGER = LoggerFactory.getLogger(CassandraDestinationAcceptanceTest.class); - private JsonNode configJson; private CassandraCqlProvider cassandraCqlProvider; @@ -36,8 +35,8 @@ protected void setup(TestDestinationEnv testEnv) { configJson = TestDataFactory.createJsonConfig( cassandraContainer.getUsername(), cassandraContainer.getPassword(), - cassandraContainer.getHost(), - cassandraContainer.getFirstMappedPort()); + HostPortResolver.resolveHost(cassandraContainer), + HostPortResolver.resolvePort(cassandraContainer)); var cassandraConfig = new CassandraConfig(configJson); cassandraCqlProvider = new CassandraCqlProvider(cassandraConfig); cassandraNameTransformer = new CassandraNameTransformer(cassandraConfig);