commit 84c3fa07da9fdcc12ed04edd8419d64a118ebc5f
author Etienne Chauchot <echauchot@apache.org> Fri Sep 19 12:16:51 2025 +0200
committer Etienne Chauchot <echauchot@apache.org> Mon Sep 22 11:15:13 2025 +0200
tree da28d28aed0a6cba1d94853374abba122b71a14e
parent 191e50aeac8b670de070ed712d6b5ac73305a2ed

[FLINK-37937] Rebase on main and reference cassandraContainer1 instead of cassandraContainer

flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/CassandraTestEnvironment.java

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