Fabian Hueske created FLINK-2936:
------------------------------------
Summary: ClassCastException when using EventTimeSourceFunction in
non-EventTime program
Key: FLINK-2936
URL: https://issues.apache.org/jira/browse/FLINK-2936
Project: Flink
Issue Type: Improvement
Components: Streaming
Affects Versions: 0.10
Reporter: Fabian Hueske
Fix For: 0.10
Using an {{EventTimeSourceFunction}} in a DataStream programs that does not
operate with {{TimeCharacteristic.EventTime}} leads to a {{ClassCastException}}
when the first {{Watermark}} is emitted:
{code}
Caused by: java.lang.ClassCastException:
org.apache.flink.streaming.api.watermark.Watermark cannot be cast to
org.apache.flink.streaming.runtime.streamrecord.StreamRecord
{code}
This exception is not very helpful for users that simply for got to set the
correct {{TimeCharacteristic}} and should be improved.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
