flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From James Yu <cyu...@gmail.com>
Subject unable to addSource to StreamExecutionEnvironment?
Date Tue, 20 Mar 2018 08:55:36 GMT

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

View raw message