You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jiabao Sun (Jira)" <ji...@apache.org> on 2024/03/18 15:15:00 UTC
[jira] [Assigned] (FLINK-34719) StreamRecordTest#testWithTimestamp fails on Azure
[ https://issues.apache.org/jira/browse/FLINK-34719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jiabao Sun reassigned FLINK-34719:
----------------------------------
Assignee: Jiabao Sun
> 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
> Assignee: Jiabao Sun
> Priority: Major
> Labels: test-stability
>
> 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)