unable to addSource to StreamExecutionEnvironment?

Posted by James Yu on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/unable-to-addSource-to-StreamExecutionEnvironment-tp19040.html

Hi,

I am following the Taxi example provided on "http://training.data-artisans.com/exercises/taxiData.html", however, I got the following error message when I copy addSource line into my Intellij IDE.

error message -->

Incompatible types. Required DataStream<TaxiRide> but 'addSource' was inferred to DataStreamSource<OUT>: no instance(s) of type variable(s) OUT exist so that DataStreamSource<OUT> conforms to DataStream<TaxiRide>

addSource line -->
DataStream<TaxiRide> rides = env.addSource(
  new TaxiRideSource("/path/to/nycTaxiRides.gz", maxDelay, servingSpeed));

My question would be: how do we addSource in latest Flink? I am running flink-1.4.2.

This is a UTF-8 formatted mail
-----------------------------------------------
James C.-C.Yu
[phone]