flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andrey Melentyev <andrey.melent...@gmail.com>
Subject Re: RideCleansingToKafka Filter Parameter Type
Date Fri, 04 Nov 2016 11:29:15 GMT
Hi daviD,

does it compile okay if you clone the https://github.com/
fhueske/flink-training-exercises/ directly without any changes? The repo
contains the example you are referring to and seems to compile just fine on
my machine both with Maven and IntelliJ.

In case it still doesn't work for you, would you mind sharing the output of
"mvn compile"?

Andrey

On Fri, Nov 4, 2016 at 12:22 PM, daviD <dunongo@yahoo.com.invalid> wrote:

> Greetings,
> First, thanks to DataArtisans for putting together Apache FlinkĀ® Training
> documentation. Its proving to be a practical way to learn both Flink and
> Scala.
> In compiling our exercise writing to Kafka, I am getting following error
> "missing parameter type" where the parameter 'r' seems not to be recognized
> in filter method. Code snippet as follows:
> val rides = env.addSource(new TaxiRideSource(input, maxEventsDelay,
> streamServingSpeed))
>
> val filteredRides = rides.filter(r => GeoUtils.isInNYC(r.startLon,
> r.startLat) && GeoUtils.isInNYC(r.endLon, r.endLat))Any advice would be
> appreciated.
> Thanks
>
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message