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();
     }
 }

Reply via email to