(flink) branch master updated: [FLINK-38983][test] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module (#27478)

[panyuepeng]

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

panyuepeng 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 d43d6c081f5 [FLINK-38983][test] Migrate the JUnit5 for 
TaskChangelogRegistryImplTest of flink-dstl-dfs module (#27478)
d43d6c081f5 is described below

commit d43d6c081f520865c43a7ec6004b25c074229165
Author: Yuepeng Pan <panyuep...@apache.org>
AuthorDate: Wed Jan 28 10:45:11 2026 +0800

    [FLINK-38983][test] Migrate the JUnit5 for TaskChangelogRegistryImplTest of 
flink-dstl-dfs module (#27478)
---
 .../changelog/fs/TaskChangelogRegistryImplTest.java   | 19 +++++++++----------
 1 file changed, 9 insertions(+), 10 deletions(-)

diff --git 
a/flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/TaskChangelogRegistryImplTest.java
 
b/flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/TaskChangelogRegistryImplTest.java
index 0d64cd654b4..45d7b32d027 100644
--- 
a/flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/TaskChangelogRegistryImplTest.java
+++ 
b/flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/TaskChangelogRegistryImplTest.java
@@ -19,39 +19,38 @@ package org.apache.flink.changelog.fs;
 
 import org.apache.flink.runtime.state.TestingStreamStateHandle;
 
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
 
 import static org.apache.flink.util.concurrent.Executors.directExecutor;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertTrue;
+import static org.assertj.core.api.Assertions.assertThat;
 
 /** {@link TaskChangelogRegistryImpl} test. */
-public class TaskChangelogRegistryImplTest {
+class TaskChangelogRegistryImplTest {
 
     @Test
-    public void testDiscardedWhenNotUsed() {
+    void testDiscardedWhenNotUsed() {
         TaskChangelogRegistry registry = new 
TaskChangelogRegistryImpl(directExecutor());
         TestingStreamStateHandle handle = new TestingStreamStateHandle();
         long refCount = 2;
         registry.startTracking(handle, refCount);
         for (int i = 0; i < refCount; i++) {
-            assertFalse(handle.isDisposed());
+            assertThat(handle.isDisposed()).isFalse();
             registry.release(handle);
         }
-        assertTrue(handle.isDisposed());
+        assertThat(handle.isDisposed()).isTrue();
     }
 
     @Test
-    public void testNotDiscardedIfStoppedTracking() {
+    void testNotDiscardedIfStoppedTracking() {
         TaskChangelogRegistry registry = new 
TaskChangelogRegistryImpl(directExecutor());
         TestingStreamStateHandle handle = new TestingStreamStateHandle();
         long refCount = 2;
         registry.startTracking(handle, refCount);
         registry.stopTracking(handle);
         for (int i = 0; i < refCount; i++) {
-            assertFalse(handle.isDisposed());
+            assertThat(handle.isDisposed()).isFalse();
             registry.release(handle);
         }
-        assertFalse(handle.isDisposed());
+        assertThat(handle.isDisposed()).isFalse();
     }
 }