Skip to content

Commit 84c3fa0

Browse files
committed
[FLINK-37937] Rebase on main and reference cassandraContainer1 instead of cassandraContainer
1 parent 191e50a commit 84c3fa0

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -289,18 +289,18 @@ public Session getSession() {
289289
}
290290

291291
public String getContactPoint() {
292-
return cassandraContainer.getHost();
292+
return cassandraContainer1.getHost();
293293
}
294294

295295
public int getPort() {
296-
return cassandraContainer.getMappedPort(CQL_PORT);
296+
return cassandraContainer1.getMappedPort(CQL_PORT);
297297
}
298298

299299
public String getUsername() {
300-
return cassandraContainer.getUsername();
300+
return cassandraContainer1.getUsername();
301301
}
302302

303303
public String getPassword() {
304-
return cassandraContainer.getPassword();
304+
return cassandraContainer1.getPassword();
305305
}
306306
}

0 commit comments

Comments
 (0)