(flink) branch master updated: [hotfix][tests] Use Junit5 import in FileSinkTest

[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 3ca8c58d112 [hotfix][tests] Use Junit5 import in FileSinkTest
3ca8c58d112 is described below

commit 3ca8c58d1127ecdbce6436e2212aeb6ce3145262
Author: slfan1989 <55643692+slfan1...@users.noreply.github.com>
AuthorDate: Mon Jun 16 07:48:41 2025 +0800

    [hotfix][tests] Use Junit5 import in FileSinkTest
    
    
    
    ---------
    
    Co-authored-by: Sergey Nuyanzin <snuyan...@confluent.io>
---
 .../org/apache/flink/connector/file/sink/FileSinkTest.java     | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/FileSinkTest.java
 
b/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/FileSinkTest.java
index 516a071dfb7..08e0635d748 100644
--- 
a/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/FileSinkTest.java
+++ 
b/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/FileSinkTest.java
@@ -23,17 +23,17 @@ import 
org.apache.flink.connector.file.sink.utils.IntegerFileSinkTestDataUtils;
 import 
org.apache.flink.connector.file.sink.utils.PartSizeAndCheckpointRollingPolicy;
 import org.apache.flink.core.fs.Path;
 
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
 
 import java.io.IOException;
 
-import static org.junit.Assert.assertEquals;
+import static org.assertj.core.api.Assertions.assertThat;
 
 /** Tests for {@link FileSink}. */
-public class FileSinkTest {
+class FileSinkTest {
 
     @Test
-    public void testCreateFileWriterWithTimerRegistered() throws IOException {
+    void testCreateFileWriterWithTimerRegistered() throws IOException {
         TestSinkInitContext ctx = new TestSinkInitContext();
         FileSink<Integer> sink =
                 FileSink.forRowFormat(
@@ -41,6 +41,6 @@ public class FileSinkTest {
                         .withRollingPolicy(new 
PartSizeAndCheckpointRollingPolicy<>(1024, true))
                         .build();
         sink.createWriter(ctx);
-        assertEquals(ctx.getTestProcessingTimeService().getNumActiveTimers(), 
1);
+        
assertThat(ctx.getTestProcessingTimeService().getNumActiveTimers()).isOne();
     }
 }