[jira] [Created] (FLINK-3082) Confusing error about ManualTimestampSourceFunction

[Shang Yuanchun (Jira)]

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)