flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: unable to addSource to StreamExecutionEnvironment?
Date Tue, 20 Mar 2018 13:53:57 GMT
Thanks for reporting back!

2018-03-20 10:42 GMT+01:00 James Yu <cyu021@gmail.com>:

> 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.
>
> This is a UTF-8 formatted mail
> -----------------------------------------------
> James C.-C.Yu
> +886988713275 <+886%20988%20713%20275>
>
> 2018-03-20 16:55 GMT+08:00 James Yu <cyu021@gmail.com>:
>
>> 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
>> +886988713275 <+886%20988%20713%20275>
>>
>
>

Mime
View raw message