Re: 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-tp19040p19048.html

Just found out that IDE seems auto import wrong class.

While "org.apache.flink.streaming.api.datastream.DataStream" is required, "org.apache.flink.streaming.api.scala.DataStream" was imported.

2018-03-20 16:55 GMT+08:00 James Yu <[hidden email]>:

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
<a href="tel:+886%20988%20713%20275" value="[phone]" target="_blank">[phone]