[FLINK-2936] ClassCastException when using EventTimeSourceFunction in non-EventTime program

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.0
• Fix Version/s: 1.0.0
• Assignee: Aljoscha Krettek
• Reporter: Fabian Hueske
• Created: 28/Oct/15 22:40
• Updated: 28/Feb/19 11:14
• Resolved: 11/Dec/15 17:05

Description

Using an EventTimeSourceFunction in a DataStream programs that does not operate with TimeCharacteristic.EventTime leads to a ClassCastException when the first Watermark is emitted:

Caused by: java.lang.ClassCastException: org.apache.flink.streaming.api.watermark.Watermark cannot be cast to org.apache.flink.streaming.runtime.streamrecord.StreamRecord

This exception is not very helpful for users that simply for got to set the correct TimeCharacteristic and should be improved.