diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecordTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecordTest.java
index f11c2ec432ef9..c98e6e2fd8c44 100644
--- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecordTest.java
+++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecordTest.java
@@ -51,10 +51,7 @@ void testWithNoTimestamp() {
                 .isEqualTo(new StreamRecord<>("test"))
                 .isEqualTo(record.asRecord());
 
-        assertThatThrownBy(record::asWatermark)
-                .isInstanceOf(ClassCastException.class)
-                .hasMessageContaining(
-                        "cannot be cast to org.apache.flink.streaming.api.watermark.Watermark");
+        assertThatThrownBy(record::asWatermark).isInstanceOf(ClassCastException.class);
     }
 
     @Test
@@ -80,10 +77,7 @@ void testWithTimestamp() {
                 .isNotEqualTo(new StreamRecord<>("foo"))
                 .isEqualTo(record.asRecord());
 
-        assertThatThrownBy(record::asWatermark)
-                .isInstanceOf(ClassCastException.class)
-                .hasMessageContaining(
-                        "cannot be cast to org.apache.flink.streaming.api.watermark.Watermark");
+        assertThatThrownBy(record::asWatermark).isInstanceOf(ClassCastException.class);
     }
 
     @Test