[jira] [Created] (FLINK-2936) ClassCastException when using EventTimeSourceFunction in non-EventTime program

["Fabian Hueske (JIRA)" <ji...@apache.org>]

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)