(hudi) branch master updated: test(flink): stabilize Sink V2 UID assertion (#19623)

[danny0405]

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

danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new bd98a49faa85 test(flink): stabilize Sink V2 UID assertion (#19623)
bd98a49faa85 is described below

commit bd98a49faa85e09dc454a979fda6d491a4c91ef1
Author: Danny Chan <yuzhao....@gmail.com>
AuthorDate: Fri Aug 14 16:37:49 2026 +0800

    test(flink): stabilize Sink V2 UID assertion (#19623)
---
 .../src/test/java/org/apache/hudi/sink/v2/utils/TestPipelinesV2.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/v2/utils/TestPipelinesV2.java
 
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/v2/utils/TestPipelinesV2.java
index 5e20e264094b..a56cc694cc91 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/v2/utils/TestPipelinesV2.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/v2/utils/TestPipelinesV2.java
@@ -48,6 +48,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertSame;
 import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTrue;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.mockStatic;
 
@@ -78,7 +79,8 @@ class TestPipelinesV2 {
 
     assertEquals(4, sink.getTransformation().getParallelism());
     assertEquals("sink_v2", sink.getTransformation().getName());
-    assertEquals("uid_sink_v2_sink_v2_test", 
sink.getTransformation().getUid());
+    assertTrue(sink.getTransformation().getUid()
+        .matches("uid_sink_v2(?:_\\d+)?_sink_v2_test"));
   }
 
   @Test