This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 8c7df6c9a60cd8aed98d670b06a8c606707e5faa Author: Etienne Chauchot <[email protected]> AuthorDate: Mon Dec 27 18:12:56 2021 +0100 [FLINK-25147] add keyspace drop because the docker image is reused and modified by the tests. --- .../streaming/connectors/cassandra/CassandraConnectorITCase.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java index f6fede9..abfbc96 100644 --- a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java +++ b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java @@ -126,6 +126,8 @@ public class CassandraConnectorITCase private static final String TABLE_NAME_VARIABLE = "$TABLE"; private static final String CREATE_KEYSPACE_QUERY = "CREATE KEYSPACE flink WITH replication= {'class':'SimpleStrategy', 'replication_factor':1};"; + private static final String DROP_KEYSPACE_QUERY = + "DROP KEYSPACE IF EXISTS flink ;"; private static final String CREATE_TABLE_QUERY = "CREATE TABLE flink." + TABLE_NAME_VARIABLE @@ -163,9 +165,11 @@ public class CassandraConnectorITCase @BeforeClass public static void startAndInitializeCassandra() { + // CASSANDRA_CONTAINER#start() already contains retrials CASSANDRA_CONTAINER.start(); cluster = CASSANDRA_CONTAINER.getCluster(); session = cluster.connect(); + session.execute(DROP_KEYSPACE_QUERY); session.execute(CREATE_KEYSPACE_QUERY); session.execute( CREATE_TABLE_QUERY.replace(TABLE_NAME_VARIABLE, TABLE_NAME_PREFIX + "initial"));
