(fluss) branch main updated: [test] Fix unstable test FlinkSinkWriterTest.testFlussSchemaChange. (#2116)

[hongshun]

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

hongshun pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new c6af64df9 [test] Fix unstable test 
FlinkSinkWriterTest.testFlussSchemaChange. (#2116)
c6af64df9 is described below

commit c6af64df9856a419fd501493be808d94b23c048f
Author: Kerwin <37063904+zhuangch...@users.noreply.github.com>
AuthorDate: Wed Dec 10 10:07:15 2025 +0800

    [test] Fix unstable test FlinkSinkWriterTest.testFlussSchemaChange. (#2116)
---
 .../apache/fluss/flink/sink/writer/FlinkSinkWriterTest.java  | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git 
a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/sink/writer/FlinkSinkWriterTest.java
 
b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/sink/writer/FlinkSinkWriterTest.java
index 9ac81ba6d..6eebba419 100644
--- 
a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/sink/writer/FlinkSinkWriterTest.java
+++ 
b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/sink/writer/FlinkSinkWriterTest.java
@@ -147,8 +147,16 @@ public class FlinkSinkWriterTest extends FlinkTestBase {
                                             new MockSinkWriterContext()))
                     .rootCause()
                     .isExactlyInstanceOf(ClassCastException.class)
-                    .hasMessageContaining(
-                            "class 
org.apache.flink.table.data.binary.BinaryStringData cannot be cast to class 
java.lang.Integer");
+                    .satisfiesAnyOf(
+                            // JDK8 format: no "class" prefix.
+                            e ->
+                                    assertThat(e.getMessage())
+                                            .contains(
+                                                    
"org.apache.flink.table.data.binary.BinaryStringData cannot be cast to 
java.lang.Integer"),
+                            e ->
+                                    assertThat(e.getMessage())
+                                            .contains(
+                                                    "class 
org.apache.flink.table.data.binary.BinaryStringData cannot be cast to class 
java.lang.Integer"));
             writer.flush(false);
         }
     }