You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ec...@apache.org on 2025/09/22 09:15:26 UTC
(flink-connector-cassandra) 08/08: [FLINK-37937] Rebase on main and reference cassandraContainer1 instead of cassandraContainer
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 <ec...@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();
}
}