This is an automated email from the ASF dual-hosted git repository. snuyanzin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit e700705ac7b84a954362c7f6bb1fe5e62973de06 Author: Sergey Nuyanzin <[email protected]> AuthorDate: Mon Aug 3 12:25:05 2026 +0200 [FLINK-40310][tests] Rename `CsvBulkWriterIT` to `CsvBulkWriterTest` --- .../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(
