[FLINK-34719] StreamRecordTest#testWithTimestamp fails on Azure

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.20.0
• Fix Version/s: 1.20.0
• Component/s: Tests
• Labels: pull-request-available test-stability
• Assignee: Jiabao Sun
• Reporter: Ryan Skraba
• Created: 18/Mar/24 13:27
• Updated: 21/Mar/24 11:03
• Resolved: 18/Mar/24 23:43

Description

The ClassCastException message expected in StreamRecordTest#testWithTimestamp as well as StreamRecordTest#testWithNoTimestamp fails on JDK 11, 17, and 21

• https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=58352&view=logs&j=f0ac5c25-1168-55a5-07ff-0e88223afed9&t=50bf7a25-bdc4-5e56-5478-c7b4511dde53&l=10341
• https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=58352&view=logs&j=675bf62c-8558-587e-2555-dcad13acefb5&t=5878eed3-cc1e-5b12-1ed0-9e7139ce0992&l=9828
• https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=58352&view=logs&j=d06b80b4-9e88-5d40-12a2-18072cf60528&t=609ecd5a-3f6e-5d0c-2239-2096b155a4d0&l=9833

Expecting throwable message:
Mar 16 01:35:07   "class org.apache.flink.streaming.runtime.streamrecord.StreamRecord cannot be cast to class org.apache.flink.streaming.api.watermark.Watermark (org.apache.flink.streaming.runtime.streamrecord.StreamRecord and org.apache.flink.streaming.api.watermark.Watermark are in unnamed module of loader 'app')"
Mar 16 01:35:07 to contain:
Mar 16 01:35:07   "cannot be cast to org.apache.flink.streaming.api.watermark.Watermark"
Mar 16 01:35:07 but did not.
Mar 16 01:35:07 
Mar 16 01:35:07 Throwable that failed the check:
Mar 16 01:35:07 
Mar 16 01:35:07 java.lang.ClassCastException: class org.apache.flink.streaming.runtime.streamrecord.StreamRecord cannot be cast to class org.apache.flink.streaming.api.watermark.Watermark (org.apache.flink.streaming.runtime.streamrecord.StreamRecord and org.apache.flink.streaming.api.watermark.Watermark are in unnamed module of loader 'app')
Mar 16 01:35:07 	at org.apache.flink.streaming.runtime.streamrecord.StreamElement.asWatermark(StreamElement.java:92)
Mar 16 01:35:07 	at org.assertj.core.api.ThrowableAssert.catchThrowable(ThrowableAssert.java:63)
Mar 16 01:35:07 	at org.assertj.core.api.AssertionsForClassTypes.catchThrowable(AssertionsForClassTypes.java:892)
 

Issue Links

• is caused by: FLINK-25544 [JUnit5 Migration] Module: flink-streaming-java
• links to: GitHub Pull Request #24519