Ryan Skraba created FLINK-34719:
-----------------------------------

             Summary: StreamRecordTest#testWithTimestamp fails on Azure
                 Key: FLINK-34719
                 URL: https://issues.apache.org/jira/browse/FLINK-34719
             Project: Flink
          Issue Type: Bug
          Components: Tests
    Affects Versions: 1.20.0
            Reporter: Ryan Skraba


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]

{code:java}
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)
 {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to