(flink) branch release-2.3 updated: [FLINK-40310][tests] Rename `CsvBulkWriterIT` to `CsvBulkWriterITCase`

[snuyanzin]

This is an automated email from the ASF dual-hosted git repository.

snuyanzin pushed a commit to branch release-2.3
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-2.3 by this push:
     new 591dce6a6d3 [FLINK-40310][tests] Rename `CsvBulkWriterIT` to 
`CsvBulkWriterITCase`
591dce6a6d3 is described below

commit 591dce6a6d3df577b9b52d935a68243b199858f7
Author: Sergey Nuyanzin <snuyan...@gmail.com>
AuthorDate: Tue Aug 4 08:20:44 2026 +0200

    [FLINK-40310][tests] Rename `CsvBulkWriterIT` to `CsvBulkWriterITCase`
---
 .../csv/{CsvBulkWriterIT.java => CsvBulkWriterITCase.java} | 14 ++++++++++++--
 1 file changed, 12 insertions(+), 2 deletions(-)

diff --git 
a/flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvBulkWriterIT.java
 
b/flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvBulkWriterITCase.java
similarity index 92%
rename from 
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvBulkWriterIT.java
rename to 
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvBulkWriterITCase.java
index aa070b22aba..349c7c9461d 100644
--- 
a/flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvBulkWriterIT.java
+++ 
b/flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvBulkWriterITCase.java
@@ -27,10 +27,13 @@ import 
org.apache.flink.connector.datagen.source.DataGeneratorSource;
 import org.apache.flink.connector.datagen.source.TestDataGenerators;
 import org.apache.flink.connector.file.sink.FileSink;
 import org.apache.flink.core.fs.FSDataOutputStream;
+import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
+import org.apache.flink.test.junit5.MiniClusterExtension;
 
 import org.apache.commons.io.FileUtils;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
 import org.junit.jupiter.api.io.TempDir;
 
 import java.io.File;
@@ -44,7 +47,14 @@ import java.util.stream.Collectors;
 
 import static org.assertj.core.api.Assertions.assertThat;
 
-public class CsvBulkWriterIT {
+class CsvBulkWriterITCase {
+
+    @RegisterExtension
+    static final MiniClusterExtension MINI_CLUSTER =
+            new MiniClusterExtension(
+                    new MiniClusterResourceConfiguration.Builder()
+                            .setNumberTaskManagers(2)
+                            .build());
 
     @TempDir File outDir;
 
@@ -53,7 +63,7 @@ public class CsvBulkWriterIT {
      * flush signal from Flink.
      */
     @Test
-    public void testNoDataIsWrittenBeforeFlinkFlush() throws Exception {
+    void testNoDataIsWrittenBeforeFlinkFlush() throws Exception {
 
         Configuration config = new Configuration();
         config.set(