(flink-connector-cassandra) 02/02: [FLINK-38485] Make setup and teardown (test environment start/stop, tables creation, test data insertion) global for the whole test case instead of once per test to avoid too long test run.

[echauchot]

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 bbc80198f1386620f46d2186d054fd3172902a09
Author: Etienne Chauchot <echauc...@apache.org>
AuthorDate: Wed Oct 8 13:45:31 2025 +0200

    [FLINK-38485] Make setup and teardown (test environment start/stop, tables 
creation, test data insertion) global for the whole test case instead of once 
per test to avoid too long test run.
---
 .../table/CassandraDynamicTableSourceITCase.java       | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git 
a/flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/table/CassandraDynamicTableSourceITCase.java
 
b/flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/table/CassandraDynamicTableSourceITCase.java
index 2345b6e..61d84ec 100644
--- 
a/flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/table/CassandraDynamicTableSourceITCase.java
+++ 
b/flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/table/CassandraDynamicTableSourceITCase.java
@@ -26,9 +26,10 @@ import org.apache.flink.test.junit5.MiniClusterExtension;
 import org.apache.flink.types.Row;
 import org.apache.flink.util.CloseableIterator;
 
-import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.TestInstance;
 import org.junit.jupiter.api.extension.ExtendWith;
 
 import java.math.BigDecimal;
@@ -43,12 +44,13 @@ import static org.assertj.core.api.Assertions.assertThat;
  * complex scenarios, edge cases, and error conditions.
  */
 @ExtendWith(MiniClusterExtension.class)
+@TestInstance(TestInstance.Lifecycle.PER_CLASS)
 class CassandraDynamicTableSourceITCase {
 
     private CassandraTestEnvironment cassandraTestEnvironment;
     private StreamTableEnvironment tableEnv;
 
-    @BeforeEach
+    @BeforeAll
     void setUp() throws Exception {
         cassandraTestEnvironment = new CassandraTestEnvironment(false);
         cassandraTestEnvironment.startUp();
@@ -60,11 +62,9 @@ class CassandraDynamicTableSourceITCase {
         insertAllTestData();
     }
 
-    @AfterEach
+    @AfterAll
     void tearDown() throws Exception {
-        if (cassandraTestEnvironment != null) {
-            cassandraTestEnvironment.tearDown();
-        }
+        cassandraTestEnvironment.tearDown();
     }
 
     private void createAllTestTables() {
@@ -1526,7 +1526,7 @@ class CassandraDynamicTableSourceITCase {
     @Test
     void testFieldProjectionAndQueryOptimization() throws Exception {
         String createFlinkTable =
-                "CREATE TABLE flink_primitives ("
+                "CREATE TABLE flink_projections ("
                         + "  id INT,"
                         + "  name STRING,"
                         + "  age INT,"
@@ -1549,7 +1549,7 @@ class CassandraDynamicTableSourceITCase {
                         + ")";
 
         tableEnv.executeSql(createFlinkTable);
-        Table result = tableEnv.sqlQuery("SELECT name, age FROM 
flink_primitives");
+        Table result = tableEnv.sqlQuery("SELECT name, age FROM 
flink_projections");
 
         List<Row> actualRows = collectResults(result, 2);