(flink) branch master updated: [FLINK-34719][streaming] Fix unstable test StreamRecordTest.testWithTimestamp above jdk8

[jiabaosun]

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

jiabaosun 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 8ec5e7e830b [FLINK-34719][streaming] Fix unstable test 
StreamRecordTest.testWithTimestamp above jdk8
8ec5e7e830b is described below

commit 8ec5e7e830b5bda30ead3638a1faa3567d80bb7b
Author: Jiabao Sun <jiabao...@apache.org>
AuthorDate: Tue Mar 19 07:42:23 2024 +0800

    [FLINK-34719][streaming] Fix unstable test 
StreamRecordTest.testWithTimestamp above jdk8
---
 .../flink/streaming/runtime/streamrecord/StreamRecordTest.java | 10 ++--------
 1 file changed, 2 insertions(+), 8 deletions(-)

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 f11c2ec432e..c98e6e2fd8c 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 @@ class StreamRecordTest {
                 .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 @@ class StreamRecordTest {
                 .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