(flink) branch master updated: [FLINK-39768][tests][JUnit5 migration] Module: flink-avro - `AvroStreamingFileSinkITCase`

[snuyanzin]

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


The following commit(s) were added to refs/heads/master by this push:
     new 5d9860c29db [FLINK-39768][tests][JUnit5 migration] Module: flink-avro 
- `AvroStreamingFileSinkITCase`
5d9860c29db is described below

commit 5d9860c29db0f14736d7c8416c032b4cc22b2b87
Author: Purushottam Sinha <psi...@confluent.io>
AuthorDate: Thu May 28 18:34:29 2026 +0530

    [FLINK-39768][tests][JUnit5 migration] Module: flink-avro - 
`AvroStreamingFileSinkITCase`
---
 .../formats/avro/AvroStreamingFileSinkITCase.java  | 26 +++++++++-------------
 1 file changed, 10 insertions(+), 16 deletions(-)

diff --git 
a/flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroStreamingFileSinkITCase.java
 
b/flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroStreamingFileSinkITCase.java
index 9d730e3dc87..e4259e65143 100644
--- 
a/flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroStreamingFileSinkITCase.java
+++ 
b/flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroStreamingFileSinkITCase.java
@@ -28,7 +28,7 @@ import org.apache.flink.streaming.api.datastream.DataStream;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import 
org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners.UniqueBucketAssigner;
 import 
org.apache.flink.streaming.api.functions.sink.filesystem.legacy.StreamingFileSink;
-import org.apache.flink.test.util.AbstractTestBaseJUnit4;
+import org.apache.flink.test.util.AbstractTestBase;
 
 import org.apache.avro.Schema;
 import org.apache.avro.file.DataFileReader;
@@ -38,9 +38,9 @@ import org.apache.avro.generic.GenericRecord;
 import org.apache.avro.io.DatumReader;
 import org.apache.avro.reflect.ReflectDatumReader;
 import org.apache.avro.specific.SpecificDatumReader;
-import org.junit.Rule;
-import org.junit.Test;
-import org.junit.rules.Timeout;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
+import org.junit.jupiter.api.io.TempDir;
 
 import java.io.File;
 import java.io.IOException;
@@ -51,6 +51,7 @@ import java.util.Arrays;
 import java.util.Collection;
 import java.util.Iterator;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 
 import static org.assertj.core.api.Assertions.assertThat;
 
@@ -58,14 +59,11 @@ import static org.assertj.core.api.Assertions.assertThat;
  * Simple integration test case for writing bulk encoded files with the {@link 
StreamingFileSink}
  * with Avro.
  */
-public class AvroStreamingFileSinkITCase extends AbstractTestBaseJUnit4 {
-
-    @Rule public final Timeout timeoutPerTest = Timeout.seconds(20);
+@Timeout(value = 20, unit = TimeUnit.SECONDS)
+class AvroStreamingFileSinkITCase extends AbstractTestBase {
 
     @Test
-    public void testWriteAvroSpecific() throws Exception {
-        File folder = TEMPORARY_FOLDER.newFolder();
-
+    void testWriteAvroSpecific(@TempDir File folder) throws Exception {
         List<Address> data =
                 Arrays.asList(
                         new Address(1, "a", "b", "c", "12345"),
@@ -94,9 +92,7 @@ public class AvroStreamingFileSinkITCase extends 
AbstractTestBaseJUnit4 {
     }
 
     @Test
-    public void testWriteAvroGeneric() throws Exception {
-        File folder = TEMPORARY_FOLDER.newFolder();
-
+    void testWriteAvroGeneric(@TempDir File folder) throws Exception {
         Schema schema = Address.getClassSchema();
         Collection<GenericRecord> data = new GenericTestDataCollection();
 
@@ -122,9 +118,7 @@ public class AvroStreamingFileSinkITCase extends 
AbstractTestBaseJUnit4 {
     }
 
     @Test
-    public void testWriteAvroReflect() throws Exception {
-        File folder = TEMPORARY_FOLDER.newFolder();
-
+    void testWriteAvroReflect(@TempDir File folder) throws Exception {
         List<Datum> data = Arrays.asList(new Datum("a", 1), new Datum("b", 2), 
new Datum("c", 3));
 
         StreamExecutionEnvironment env = 
StreamExecutionEnvironment.getExecutionEnvironment();