This is an automated email from the ASF dual-hosted git repository. echauchot pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-cassandra.git
commit 84c3fa07da9fdcc12ed04edd8419d64a118ebc5f Author: Etienne Chauchot <echauc...@apache.org> AuthorDate: Fri Sep 19 12:16:51 2025 +0200 [FLINK-37937] Rebase on main and reference cassandraContainer1 instead of cassandraContainer --- .../flink/connector/cassandra/CassandraTestEnvironment.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/CassandraTestEnvironment.java b/flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/CassandraTestEnvironment.java index 59604a2..7a8f5d3 100644 --- a/flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/CassandraTestEnvironment.java +++ b/flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/CassandraTestEnvironment.java @@ -289,18 +289,18 @@ public class CassandraTestEnvironment implements TestResource { } public String getContactPoint() { - return cassandraContainer.getHost(); + return cassandraContainer1.getHost(); } public int getPort() { - return cassandraContainer.getMappedPort(CQL_PORT); + return cassandraContainer1.getMappedPort(CQL_PORT); } public String getUsername() { - return cassandraContainer.getUsername(); + return cassandraContainer1.getUsername(); } public String getPassword() { - return cassandraContainer.getPassword(); + return cassandraContainer1.getPassword(); } }