Niels Basjes created FLINK-3082:
-----------------------------------
Summary: Confusing error about ManualTimestampSourceFunction
Key: FLINK-3082
URL: https://issues.apache.org/jira/browse/FLINK-3082
Project: Flink
Issue Type: Bug
Reporter: Niels Basjes
I wrote a source like this:
{code}
public class Foo extends RichSourceFunction<Bar> {
{code}
and then did
{code}
ctx.collectWithTimestamp(event, event.eventTimestamp);
{code}
I got this error:
{code}
Caused by: java.lang.UnsupportedOperationException: Automatic-Timestamp sources
cannot emit elements with a timestamp. See interface
ManualTimestampSourceFunction if you want to manually assign timestamps to
elements.
at
org.apache.flink.streaming.api.operators.StreamSource$NonTimestampContext.collectWithTimestamp(StreamSource.java:97)
{code}
After some digging it turns out that {{ManualTimestampSourceFunction}} was
renamed to {{EventTimeSourceFunction}} and apparently the old name still
lingers in this error message.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
