[FLINK-34719][streaming] Fix unstable test StreamRecordTest.testWithT…

…imestamp above jdk8
apache · Mar 18, 2024 · 8ec5e7e · 8ec5e7e
1 parent 841f23c
commit 8ec5e7e
Showing 1 changed file with 2 additions and 8 deletions.
diff --git a/...-java/src/test/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecordTest.java b/...-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